etl_lib package

Subpackages

• etl_lib.cli package
  • Submodules
    • etl_lib.cli.run_tools module
      • delete_runs()
  • Module contents
• etl_lib.core package
  • Submodules
    • etl_lib.core.BatchProcessor module
      • BatchProcessor
      • BatchResults
      • append_result()
    • etl_lib.core.ClosedLoopBatchProcessor module
      • ClosedLoopBatchProcessor
    • etl_lib.core.ETLContext module
      • ETLContext
      • Neo4jContext
      • QueryResult
      • SQLContext
      • append_results()
      • gds()
    • etl_lib.core.ParallelBatchProcessor module
      • ParallelBatchProcessor
      • ParallelBatchResult
    • etl_lib.core.ProgressReporter module
      • Neo4jProgressReporter
      • ProgressReporter
      • get_reporter()
    • etl_lib.core.SplittingBatchProcessor module
      • SplittingBatchProcessor
      • dict_id_extractor()
      • tuple_id_extractor()
    • etl_lib.core.Task module
      • ParallelTaskGroup
      • Task
      • TaskGroup
      • TaskReturn
    • etl_lib.core.ValidationBatchProcessor module
      • ValidationBatchProcessor
    • etl_lib.core.utils module
      • add_sigint_handler()
      • merge_summery()
      • setup_logging()
  • Module contents
• etl_lib.data_sink package
  • Submodules
    • etl_lib.data_sink.CSVBatchSink module
      • CSVBatchSink
    • etl_lib.data_sink.CypherBatchSink module
      • CypherBatchSink
    • etl_lib.data_sink.SQLBatchSink module
      • SQLBatchSink
  • Module contents
• etl_lib.data_source package
  • Submodules
    • etl_lib.data_source.CSVBatchSource module
      • CSVBatchSource
    • etl_lib.data_source.CypherBatchSource module
      • CypherBatchSource
    • etl_lib.data_source.SQLBatchSource module
      • SQLBatchSource
  • Module contents
• etl_lib.task package
  • Subpackages
    • etl_lib.task.data_loading package
      • Submodules
      • Module contents
  • Submodules
    • etl_lib.task.CreateReportingConstraintsTask module
      • CreateReportingConstraintsTask
    • etl_lib.task.ExecuteCypherTask module
      • ExecuteCypherTask
    • etl_lib.task.GDSTask module
      • GDSTask
      • transform_dict()
  • Module contents

Module contents

Building blocks for ETL pipelines.