nv_ingest.modules package

Subpackages

• nv_ingest.modules.extractors package
  • Module contents
• nv_ingest.modules.filters package
  • Module contents
• nv_ingest.modules.injectors package
  • Submodules
  • nv_ingest.modules.injectors.metadata_injector module
    • on_data()
  • nv_ingest.modules.injectors.task_injection module
    • on_data()
  • Module contents
• nv_ingest.modules.sinks package
  • Submodules
  • nv_ingest.modules.sinks.message_broker_task_sink module
    • create_json_payload()
    • extract_data_frame()
    • handle_failure()
    • process_and_forward()
    • push_to_broker()
    • split_large_dict()
  • nv_ingest.modules.sinks.vdb_task_sink module
    • AccumulationStats
      • msg_count
      • last_insert_time
      • data
      • data
      • last_insert_time
      • msg_count
    • preprocess_vdb_resources()
  • Module contents
• nv_ingest.modules.sources package
  • Submodules
  • nv_ingest.modules.sources.message_broker_task_source module
    • fetch_and_process_messages()
    • process_message()
  • Module contents
• nv_ingest.modules.storages package
  • Submodules
  • nv_ingest.modules.storages.image_storage module
    • upload_images()
  • Module contents
• nv_ingest.modules.telemetry package
  • Submodules
  • nv_ingest.modules.telemetry.job_counter module
  • nv_ingest.modules.telemetry.otel_meter module
    • sanitize_name()
  • nv_ingest.modules.telemetry.otel_tracer module
    • create_span_with_timestamps()
    • extract_annotated_task_results()
    • extract_timestamps_from_message()
    • uuid_to_trace_id()
  • Module contents
• nv_ingest.modules.transforms package
  • Submodules
  • nv_ingest.modules.transforms.embed_extractions module
  • nv_ingest.modules.transforms.text_splitter module
  • Module contents

Module contents