IoTAnalytics / Client / start_pipeline_reprocessing

start_pipeline_reprocessing#

IoTAnalytics.Client.start_pipeline_reprocessing(**kwargs)#

Starts the reprocessing of raw message data through the pipeline.

See also: AWS API Documentation

Request Syntax

response = client.start_pipeline_reprocessing(
    pipelineName='string',
    startTime=datetime(2015, 1, 1),
    endTime=datetime(2015, 1, 1),
    channelMessages={
        's3Paths': [
            'string',
        ]
    }
)
Parameters:

  • pipelineName (string) –

    [REQUIRED]

    The name of the pipeline on which to start reprocessing.

  • startTime (datetime) –

    The start time (inclusive) of raw message data that is reprocessed.

    If you specify a value for the startTime parameter, you must not use the channelMessages object.

  • endTime (datetime) –

    The end time (exclusive) of raw message data that is reprocessed.

    If you specify a value for the endTime parameter, you must not use the channelMessages object.

  • channelMessages (dict) –

    Specifies one or more sets of channel messages that you want to reprocess.

    If you use the channelMessages object, you must not specify a value for startTime and endTime.

    • s3Paths (list) –

      Specifies one or more keys that identify the Amazon Simple Storage Service (Amazon S3) objects that save your channel messages.

      You must use the full path for the key.

      Example path: channel/mychannel/__dt=2020-02-29 00:00:00/1582940490000_1582940520000_123456789012_mychannel_0_2118.0.json.gz

      • (string) –

Return type:

dict

Returns:

Response Syntax

{
    'reprocessingId': 'string'
}

Response Structure

  • (dict) –

    • reprocessingId (string) –

      The ID of the pipeline reprocessing activity that was started.

Exceptions