describe_batch_load_task

TimestreamWrite.Client.describe_batch_load_task(**kwargs)

Returns information about the batch load task, including configurations, mappings, progress, and other details. Service quotas apply. See code sample for details.

See also: AWS API Documentation

Request Syntax

response = client.describe_batch_load_task(
    TaskId='string'
)
Parameters
TaskId (string) --

[REQUIRED]

The ID of the batch load task.

Return type
dict
Returns
Response Syntax
{
    'BatchLoadTaskDescription': {
        'TaskId': 'string',
        'ErrorMessage': 'string',
        'DataSourceConfiguration': {
            'DataSourceS3Configuration': {
                'BucketName': 'string',
                'ObjectKeyPrefix': 'string'
            },
            'CsvConfiguration': {
                'ColumnSeparator': 'string',
                'EscapeChar': 'string',
                'QuoteChar': 'string',
                'NullValue': 'string',
                'TrimWhiteSpace': True|False
            },
            'DataFormat': 'CSV'
        },
        'ProgressReport': {
            'RecordsProcessed': 123,
            'RecordsIngested': 123,
            'ParseFailures': 123,
            'RecordIngestionFailures': 123,
            'FileFailures': 123,
            'BytesMetered': 123
        },
        'ReportConfiguration': {
            'ReportS3Configuration': {
                'BucketName': 'string',
                'ObjectKeyPrefix': 'string',
                'EncryptionOption': 'SSE_S3'|'SSE_KMS',
                'KmsKeyId': 'string'
            }
        },
        'DataModelConfiguration': {
            'DataModel': {
                'TimeColumn': 'string',
                'TimeUnit': 'MILLISECONDS'|'SECONDS'|'MICROSECONDS'|'NANOSECONDS',
                'DimensionMappings': [
                    {
                        'SourceColumn': 'string',
                        'DestinationColumn': 'string'
                    },
                ],
                'MultiMeasureMappings': {
                    'TargetMultiMeasureName': 'string',
                    'MultiMeasureAttributeMappings': [
                        {
                            'SourceColumn': 'string',
                            'TargetMultiMeasureAttributeName': 'string',
                            'MeasureValueType': 'DOUBLE'|'BIGINT'|'BOOLEAN'|'VARCHAR'|'TIMESTAMP'
                        },
                    ]
                },
                'MixedMeasureMappings': [
                    {
                        'MeasureName': 'string',
                        'SourceColumn': 'string',
                        'TargetMeasureName': 'string',
                        'MeasureValueType': 'DOUBLE'|'BIGINT'|'VARCHAR'|'BOOLEAN'|'TIMESTAMP'|'MULTI',
                        'MultiMeasureAttributeMappings': [
                            {
                                'SourceColumn': 'string',
                                'TargetMultiMeasureAttributeName': 'string',
                                'MeasureValueType': 'DOUBLE'|'BIGINT'|'BOOLEAN'|'VARCHAR'|'TIMESTAMP'
                            },
                        ]
                    },
                ],
                'MeasureNameColumn': 'string'
            },
            'DataModelS3Configuration': {
                'BucketName': 'string',
                'ObjectKey': 'string'
            }
        },
        'TargetDatabaseName': 'string',
        'TargetTableName': 'string',
        'TaskStatus': 'CREATED'|'IN_PROGRESS'|'FAILED'|'SUCCEEDED'|'PROGRESS_STOPPED'|'PENDING_RESUME',
        'RecordVersion': 123,
        'CreationTime': datetime(2015, 1, 1),
        'LastUpdatedTime': datetime(2015, 1, 1),
        'ResumableUntil': datetime(2015, 1, 1)
    }
}

Response Structure

  • (dict) --
    • BatchLoadTaskDescription (dict) --

      Description of the batch load task.

      • TaskId (string) --

        The ID of the batch load task.

      • ErrorMessage (string) --
      • DataSourceConfiguration (dict) --

        Configuration details about the data source for a batch load task.

        • DataSourceS3Configuration (dict) --

          Configuration of an S3 location for a file which contains data to load.

          • BucketName (string) --

            The bucket name of the customer S3 bucket.

          • ObjectKeyPrefix (string) --
        • CsvConfiguration (dict) --

          A delimited data format where the column separator can be a comma and the record separator is a newline character.

          • ColumnSeparator (string) --

            Column separator can be one of comma (','), pipe ('|), semicolon (';'), tab('/t'), or blank space (' ').

          • EscapeChar (string) --

            Escape character can be one of

          • QuoteChar (string) --

            Can be single quote (') or double quote (").

          • NullValue (string) --

            Can be blank space (' ').

          • TrimWhiteSpace (boolean) --

            Specifies to trim leading and trailing white space.

        • DataFormat (string) --

          This is currently CSV.

      • ProgressReport (dict) --
        • RecordsProcessed (integer) --
        • RecordsIngested (integer) --
        • ParseFailures (integer) --
        • RecordIngestionFailures (integer) --
        • FileFailures (integer) --
        • BytesMetered (integer) --
      • ReportConfiguration (dict) --

        Report configuration for a batch load task. This contains details about where error reports are stored.

        • ReportS3Configuration (dict) --

          Configuration of an S3 location to write error reports and events for a batch load.

          • BucketName (string) --
          • ObjectKeyPrefix (string) --
          • EncryptionOption (string) --
          • KmsKeyId (string) --
      • DataModelConfiguration (dict) --

        Data model configuration for a batch load task. This contains details about where a data model for a batch load task is stored.

        • DataModel (dict) --
          • TimeColumn (string) --

            Source column to be mapped to time.

          • TimeUnit (string) --

            The granularity of the timestamp unit. It indicates if the time value is in seconds, milliseconds, nanoseconds, or other supported values. Default is MILLISECONDS .

          • DimensionMappings (list) --

            Source to target mappings for dimensions.

            • (dict) --
              • SourceColumn (string) --
              • DestinationColumn (string) --
          • MultiMeasureMappings (dict) --

            Source to target mappings for multi-measure records.

            • TargetMultiMeasureName (string) --
            • MultiMeasureAttributeMappings (list) --
              • (dict) --
                • SourceColumn (string) --
                • TargetMultiMeasureAttributeName (string) --
                • MeasureValueType (string) --
          • MixedMeasureMappings (list) --

            Source to target mappings for measures.

            • (dict) --
              • MeasureName (string) --
              • SourceColumn (string) --
              • TargetMeasureName (string) --
              • MeasureValueType (string) --
              • MultiMeasureAttributeMappings (list) --
                • (dict) --
                  • SourceColumn (string) --
                  • TargetMultiMeasureAttributeName (string) --
                  • MeasureValueType (string) --
          • MeasureNameColumn (string) --
        • DataModelS3Configuration (dict) --
          • BucketName (string) --
          • ObjectKey (string) --
      • TargetDatabaseName (string) --
      • TargetTableName (string) --
      • TaskStatus (string) --

        Status of the batch load task.

      • RecordVersion (integer) --
      • CreationTime (datetime) --

        The time when the Timestream batch load task was created.

      • LastUpdatedTime (datetime) --

        The time when the Timestream batch load task was last updated.

      • ResumableUntil (datetime) --

Exceptions

  • TimestreamWrite.Client.exceptions.InternalServerException
  • TimestreamWrite.Client.exceptions.ThrottlingException
  • TimestreamWrite.Client.exceptions.AccessDeniedException
  • TimestreamWrite.Client.exceptions.ResourceNotFoundException
  • TimestreamWrite.Client.exceptions.InvalidEndpointException