ctrutils
11.0.0

Guías de Usuario

  • Guía de Inicio
    • Instalación
    • Scheduler Básico
    • Pipeline ETL con Dependencias
    • InfluxDB Básico
    • Consultar Datos
    • Logging Básico
    • Próximos Pasos

Referencia de API

  • Referencia de API
    • InfluxDB - Referencia de API
      • Clase Principal
        • InfluxdbOperation
    • Scheduler - Referencia de API
      • Clase Scheduler
        • Scheduler
      • Clase Task
        • Task
      • Enum JobState
        • JobState
      • Clase JobMetrics
        • JobMetrics
    • Handler - Referencia de API
      • LoggingHandler
        • LoggingHandler
      • LokiHandler
        • LokiHandler
      • TelegramBotHandler
        • TelegramBotHandler
    • Índice de Módulos
  • InfluxDB - Referencia de API
    • Clase Principal
      • InfluxdbOperation
        • InfluxdbOperation.__init__()
        • InfluxdbOperation.enable_logging()
        • InfluxdbOperation.get_metrics()
        • InfluxdbOperation.reset_metrics()
        • InfluxdbOperation.transaction()
        • InfluxdbOperation.get_client_info
        • InfluxdbOperation.get_client
        • InfluxdbOperation.close_client()
        • InfluxdbOperation.switch_database()
        • InfluxdbOperation.get_data()
        • InfluxdbOperation.query_to_dataframe()
        • InfluxdbOperation.read_last_n_points()
        • InfluxdbOperation.read_time_range()
        • InfluxdbOperation.get_measurements()
        • InfluxdbOperation.get_databases()
        • InfluxdbOperation.normalize_value_to_write()
        • InfluxdbOperation.write_points()
        • InfluxdbOperation.write_dataframe()
        • InfluxdbOperation.write_dataframe_parallel()
        • InfluxdbOperation.downsample_data()
        • InfluxdbOperation.create_continuous_query()
        • InfluxdbOperation.list_continuous_queries()
        • InfluxdbOperation.drop_continuous_query()
        • InfluxdbOperation.backup_measurement()
        • InfluxdbOperation.restore_measurement()
        • InfluxdbOperation.calculate_data_quality_metrics()
        • InfluxdbOperation.query_builder()
        • InfluxdbOperation.execute_query_builder()
        • InfluxdbOperation.delete()
        • InfluxdbOperation.get_field_keys_grouped_by_type()
        • InfluxdbOperation.build_query_fields()
        • InfluxdbOperation.list_databases()
        • InfluxdbOperation.database_exists()
        • InfluxdbOperation.create_database()
        • InfluxdbOperation.drop_database()
        • InfluxdbOperation.list_measurements()
        • InfluxdbOperation.measurement_exists()
        • InfluxdbOperation.drop_measurement()
        • InfluxdbOperation.list_tags()
        • InfluxdbOperation.list_tag_values()
        • InfluxdbOperation.list_fields()
        • InfluxdbOperation.get_measurement_cardinality()
        • InfluxdbOperation.get_retention_policies()
        • InfluxdbOperation.count_points()
        • InfluxdbOperation.get_database_info()
        • InfluxdbOperation.get_measurement_info()
  • Scheduler - Referencia de API
    • Clase Scheduler
      • Scheduler
        • Scheduler.__init__()
        • Scheduler.add_task()
        • Scheduler.add_job()
        • Scheduler.remove_job()
        • Scheduler.get_jobs()
        • Scheduler.get_task_metrics()
        • Scheduler.get_all_metrics()
        • Scheduler.start()
        • Scheduler.shutdown()
        • Scheduler.pause_job()
        • Scheduler.resume_job()
        • Scheduler.reschedule_job()
        • Scheduler.is_running()
        • Scheduler.print_jobs()
    • Clase Task
      • Task
        • Task.__init__()
    • Enum JobState
      • JobState
        • JobState.PENDING
        • JobState.RUNNING
        • JobState.SUCCESS
        • JobState.FAILED
        • JobState.RETRYING
        • JobState.SKIPPED
        • JobState.PENDING
        • JobState.RUNNING
        • JobState.SUCCESS
        • JobState.FAILED
        • JobState.RETRYING
        • JobState.SKIPPED
    • Clase JobMetrics
      • JobMetrics
        • JobMetrics.total_runs
        • JobMetrics.successes
        • JobMetrics.failures
        • JobMetrics.retries
        • JobMetrics.last_run_time
        • JobMetrics.last_duration
        • JobMetrics.last_state
        • JobMetrics.avg_duration
        • JobMetrics.__init__()
        • JobMetrics.record_run()
        • JobMetrics.to_dict()
  • Handler - Referencia de API
    • LoggingHandler
      • LoggingHandler
        • LoggingHandler.__init__()
        • LoggingHandler.create_stream_handler()
        • LoggingHandler.create_file_handler()
        • LoggingHandler.create_size_rotating_file_handler()
        • LoggingHandler.create_timed_rotating_file_handler()
        • LoggingHandler.create_loki_handler()
        • LoggingHandler.create_telegram_handler()
        • LoggingHandler.add_handlers()
        • LoggingHandler.remove_handlers()
        • LoggingHandler.quick_console_logger()
        • LoggingHandler.quick_file_logger()
        • LoggingHandler.production_logger()
        • LoggingHandler.log_exception_and_exit()
    • LokiHandler
      • LokiHandler
        • LokiHandler.__init__()
        • LokiHandler.emit()
        • LokiHandler.flush()
        • LokiHandler.close()
    • TelegramBotHandler
      • TelegramBotHandler
        • TelegramBotHandler.__init__()
        • TelegramBotHandler.emit()

Ejemplos

  • Ejemplos de InfluxDB
    • Validación de Datos
    • Escritura Paralela
    • Backup y Restore
    • Consultas Avanzadas
    • Ver Código Completo
    • Referencia de API
  • Ejemplos de Scheduler
    • Scheduler Básico con Cron
    • Pipeline ETL con Dependencias
    • Tarea con Callbacks
    • Ejecución Condicional
    • Monitoreo de Métricas
    • Referencia de API

Desarrollo

  • Changelog
    • Changelog
      • [11.0.0] - 2025-11-01
        • Added
        • Changed
        • Removed
        • Dependencies
        • Fixed
      • [10.x.x] - Previous Versions
      • Types of Changes
  • Contribuir a ctrutils
    • Guía de Contribución a ctrutils
      • 🚀 Inicio Rápido
        • 1. Fork y Clone
        • 2. Setup del Entorno
        • 3. Crear una Rama
      • 📝 Proceso de Desarrollo
        • 1. Escribir Tests Primero (TDD)
        • 2. Implementar la Funcionalidad
        • 3. Ejecutar Tests
        • 4. Verificar Calidad del Código
      • ✅ Checklist Antes de Commit
      • 📋 Estándares de Código
        • Estilo
        • Tests
      • 🎯 Tipos de Contribuciones
        • 🐛 Bug Fixes
        • ✨ Nuevas Funcionalidades
        • 📚 Documentación
        • 🧪 Tests
      • 🔄 Pull Request
        • Título
        • Descripción
      • 🏗️ Arquitectura del Proyecto
      • 🎓 Recursos
      • 📞 Obtener Ayuda
      • 📜 Código de Conducta
      • 🎉 Agradecimientos
ctrutils
  • Referencia de API
  • Ver código fuente de la página

Referencia de API

Documentación completa de la API generada automáticamente desde docstrings.

  • InfluxDB - Referencia de API
    • Clase Principal
  • Scheduler - Referencia de API
    • Clase Scheduler
    • Clase Task
    • Enum JobState
    • Clase JobMetrics
  • Handler - Referencia de API
    • LoggingHandler
    • LokiHandler
    • TelegramBotHandler

Índice de Módulos

  • Índice de Módulos

Anterior Siguiente

© Derechos de autor 2025, Cristian Tacoronte Rivero.

Compilado con Sphinx usando un tema proporcionado por Read the Docs.