VideoIngestFragmentPipeline

Bases: Thread

A threaded (threading.Thread) pipeline for ingesting VideoIngestFragment messages, downloading the referenced video chunks from S3, decoding them into frames, and pushing them to a given output queue.

The input_queue expects VideoIngestFragment messages.

To start streaming do VideoIngestFragmentPipeline.start().

Attributes:
  • camera_id (str) –

    Identifier for the camera; used to track source and associate metrics.

  • output_queue (Queue[DecodedFrame]) –

    Where decoded frames will be pushed.

  • metrics_queue (Optional[Queue[VideoIngestFragmentMetric]]) –

    Optional queue where periodic metric snapshots are sent.

stop()

Stop the pipeline and all associated threads.