要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击[此处](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html)了解更多信息。本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。 # CreateBatchLoadTask 创建新的 Timestream 批量加载任务。批量加载任务处理来自 S3 位置的 CSV 源数据，并将其写入 Timestream 表。从源到目标的映射在批量加载任务中进行定义。错误和事件会写入位于 S3 位置的报告中。对于报告，如果未指定 AWS KMS 密钥，则在可选的情况下`SSE_S3`，将使用 S3 托管密钥对报告进行加密。否则，这会引发错误。有关更多信息，请参阅 [AWS 托管式密钥](https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#aws-managed-cmk)。[适用服务配额](https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html)。有关详细信息，请参阅[代码示例](https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.create-batch-load.html)。 ## 请求语法 ``` { "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" } ``` ## 请求参数有关所有操作的通用参数的信息，请参阅[常用参数](CommonParameters.md)。请求接受采用 JSON 格式的以下数据。 ** [ClientToken](#API_CreateBatchLoadTask_RequestSyntax) ** 类型：字符串长度限制：最小长度为 1。长度上限为 64。必需：否 ** [DataModelConfiguration](#API_CreateBatchLoadTask_RequestSyntax) ** 类型：[DataModelConfiguration](API_DataModelConfiguration.md) 对象必需：否 ** [DataSourceConfiguration](#API_CreateBatchLoadTask_RequestSyntax) ** 定义批量加载任务数据来源的配置详细信息。类型：[DataSourceConfiguration](API_DataSourceConfiguration.md) 对象是否必需：是 ** [RecordVersion](#API_CreateBatchLoadTask_RequestSyntax) ** 类型：长整型必需：否 ** [ReportConfiguration](#API_CreateBatchLoadTask_RequestSyntax) ** 批量加载任务的报告配置。这包含有关错误报告存储位置的详细信息。类型：[ReportConfiguration](API_ReportConfiguration.md) 对象是否必需：是 ** [TargetDatabaseName](#API_CreateBatchLoadTask_RequestSyntax) ** 批量加载任务的目标 Timestream 数据库。类型：字符串模式：`[a-zA-Z0-9_.-]+` 是否必需：是 ** [TargetTableName](#API_CreateBatchLoadTask_RequestSyntax) ** 批量加载任务的目标 Timestream 表。类型：字符串模式：`[a-zA-Z0-9_.-]+` 必需：是 ## 响应语法 ``` { "TaskId": "string" } ``` ## 响应元素如果此操作成功，则该服务将会发送回 HTTP 200 响应。服务以 JSON 格式返回以下数据。 ** [TaskId](#API_CreateBatchLoadTask_ResponseSyntax) ** 批量加载任务的 ID。类型：字符串长度限制：最小长度为 3。最大长度为 32。模式：`[A-Z0-9]+` ## 错误有关所有操作的常见错误的信息，请参阅[常见错误](CommonErrors.md)。 ** 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 ## 另请参阅有关以特定语言之一使用此 API 的更多信息 AWS SDKs，请参阅以下内容： + [AWS 命令行界面 V2](https://docs.aws.amazon.com/goto/cli2/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于.NET 的 SDK V4](https://docs.aws.amazon.com/goto/DotNetSDKV4/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 C\$1\$1 的 SDK](https://docs.aws.amazon.com/goto/SdkForCpp/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 Go v2 的 SDK](https://docs.aws.amazon.com/goto/SdkForGoV2/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 Java 的 SDK V2](https://docs.aws.amazon.com/goto/SdkForJavaV2/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS JavaScript V3 版软件开发工具包](https://docs.aws.amazon.com/goto/SdkForJavaScriptV3/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 Kotlin 的 SDK](https://docs.aws.amazon.com/goto/SdkForKotlin/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 PHP 的 SDK V3](https://docs.aws.amazon.com/goto/SdkForPHPV3/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS Python 软件开发工具包](https://docs.aws.amazon.com/goto/boto3/timestream-write-2018-11-01/CreateBatchLoadTask) + [AWS 适用于 Ruby V3 的 SDK](https://docs.aws.amazon.com/goto/SdkForRubyV3/timestream-write-2018-11-01/CreateBatchLoadTask)