CreateBatchLoadTask - Amazon Timestream

有关与适用于 LiveAnalytics 的 Amazon Timestream 类似的功能,可以考虑使用适用于 InfluxDB 的 Amazon Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间,以实现实时分析。点击此处了解更多信息。

CreateBatchLoadTask

创建新的 Timestream 批量加载任务。批量加载任务处理来自 S3 位置的 CSV 源数据,并将其写入 Timestream 表。从源到目标的映射在批量加载任务中进行定义。错误和事件会写入位于 S3 位置的报告中。对于报告,如果未指定 AWS KMS 密钥,且在选项为 SSE_S3 时,报告将使用 S3 托管密钥进行加密。否则,这会引发错误。有关更多信息,请参阅 AWS 托管式密钥适用服务配额。有关详细信息,请参阅代码示例

请求语法

{ "ClientToken": "string", "DataModelConfiguration": { "DataModel": { "DimensionMappings": [ { "DestinationColumn": "string", "SourceColumn": "string" } ], "MeasureNameColumn": "string", "MixedMeasureMappings": [ { "MeasureName": "string", "MeasureValueType": "string", "MultiMeasureAttributeMappings": [ { "MeasureValueType": "string", "SourceColumn": "string", "TargetMultiMeasureAttributeName": "string" } ], "SourceColumn": "string", "TargetMeasureName": "string" } ], "MultiMeasureMappings": { "MultiMeasureAttributeMappings": [ { "MeasureValueType": "string", "SourceColumn": "string", "TargetMultiMeasureAttributeName": "string" } ], "TargetMultiMeasureName": "string" }, "TimeColumn": "string", "TimeUnit": "string" }, "DataModelS3Configuration": { "BucketName": "string", "ObjectKey": "string" } }, "DataSourceConfiguration": { "CsvConfiguration": { "ColumnSeparator": "string", "EscapeChar": "string", "NullValue": "string", "QuoteChar": "string", "TrimWhiteSpace": boolean }, "DataFormat": "string", "DataSourceS3Configuration": { "BucketName": "string", "ObjectKeyPrefix": "string" } }, "RecordVersion": number, "ReportConfiguration": { "ReportS3Configuration": { "BucketName": "string", "EncryptionOption": "string", "KmsKeyId": "string", "ObjectKeyPrefix": "string" } }, "TargetDatabaseName": "string", "TargetTableName": "string" }

请求参数

有关所有操作的通用参数的信息,请参阅常用参数

请求接受采用 JSON 格式的以下数据。

ClientToken

类型:字符串

长度限制:长度下限为 1。长度上限为 64。

必需:否

DataModelConfiguration

类型:DataModelConfiguration 对象

必需:否

DataSourceConfiguration

定义批量加载任务数据来源的配置详细信息。

类型:DataSourceConfiguration 对象

必需:是

RecordVersion

类型:长整型

必需:否

ReportConfiguration

批量加载任务的报告配置。这包含有关错误报告存储位置的详细信息。

类型:ReportConfiguration 对象

必需:是

TargetDatabaseName

批量加载任务的目标 Timestream 数据库。

类型:字符串

模式:[a-zA-Z0-9_.-]+

必需:是

TargetTableName

批量加载任务的目标 Timestream 表。

类型:字符串

模式:[a-zA-Z0-9_.-]+

必需:是

响应语法

{ "TaskId": "string" }

响应元素

如果此操作成功,则该服务将会发送回 HTTP 200 响应。

服务以 JSON 格式返回以下数据。

TaskId

批量加载任务的 ID。

类型:字符串

长度约束:最小长度为 3。最大长度为 32。

模式:[A-Z0-9]+

错误

有关所有操作的常见错误的信息,请参阅常见错误

AccessDeniedException

您无权执行此操作。

HTTP 状态代码:400

ConflictException

Timestream 无法处理此请求,因为其中包含已存在的资源。

HTTP 状态代码:400

InternalServerException

由于内部服务器错误,Timestream 无法完全处理此请求。

HTTP 状态代码:500

InvalidEndpointException

请求的端点无效。

HTTP 状态代码:400

ResourceNotFoundException

该操作试图访问不存在的资源。该资源可能未正确指定,或其状态可能不是“活动”状态。

HTTP 状态代码:400

ServiceQuotaExceededException

已超出此账户的资源实例配额。

HTTP 状态代码:400

ThrottlingException

用户发出的请求过多,已超出服务配额。请求已被阻止。

HTTP 状态代码:400

ValidationException

请求无效或格式错误。

HTTP 状态代码:400

另请参阅

有关在特定语言的 AWS SDK 中使用此 API 的更多信息,请参阅以下内容: