Skip to content

PipeSourceSqsQueueParameters

Source code in docs_src/capo_pipes/types/pipe_source_sqs_queue_parameters.py 
12
13
14
15
16
17
18
class PipeSourceSqsQueueParameters(TypedDict, closed=True):
    batch_size: NotRequired["capo_pipes.types.limit_max10000.LimitMax10000"]
    """<p>The maximum number of records to include in each batch.</p>"""
    maximum_batching_window_in_seconds: NotRequired[
        "capo_pipes.types.maximum_batching_window_in_seconds.MaximumBatchingWindowInSeconds"
    ]
    """<p>The maximum length of a time to wait for events.</p>"""

batch_size instance-attribute 

batch_size: NotRequired[LimitMax10000]

The maximum number of records to include in each batch.

maximum_batching_window_in_seconds instance-attribute 

maximum_batching_window_in_seconds: NotRequired[MaximumBatchingWindowInSeconds]

The maximum length of a time to wait for events.