本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
使用 CreateBulkImportJobAPI 操作将数据从 Amazon S3 传输到 AWS IoT SiteWise。CreateBulkImportJobAPI 支持摄取大量历史数据，并支持小批量缓冲摄取分析数据流。是一种经济高效的数据摄取机制。下面的示例使用了 AWS CLI。
重要
在创建批量导入任务之前，必须启用 AWS IoT SiteWise 热层或 AWS IoT SiteWise 冷层。有关更多信息，请参阅 在中配置存储设置 AWS IoT SiteWise。
CreateBulkImportJobAPI 支持将历史数据提取到， AWS IoT SiteWise 并可以选择设置参数。 adaptive-ingestion-flag
-
在设置为
false时，该 API 会在不触发计算或通知的情况下摄取历史数据。 -
在设置为
true时，该 API 会在七天内摄取新数据、计算指标并转换数据，以优化持续分析和通知。
运行以下命令。file-name替换为包含批量导入任务配置的文件的名称。
aws iotsitewise create-bulk-import-job --cli-input-json file://file-name.json
例 批量导入作业配置
以下是配置设置示例：
-
将
adaptive-ingestion-flag替换为true或false。-
如果设置为
false，则批量导入作业会将历史数据摄取到 AWS IoT SiteWise。 -
如果设置为
true，则批量导入作业会执行以下操作：-
将新数据摄入。 AWS IoT SiteWise
-
计算指标和转换，并支持对时间戳在七天内的数据发出通知。
-
-
-
delete-files-after-import-flag替换true为可在将数据摄入到 AWS IoT SiteWise 温层存储后从 Amazon S3 数据存储桶中删除。 -
将 amzn-s3-demo-bucket 替换为发送与此批量导入任务相关的错误的 Amazon S3 存储桶的
-for-errors名称。 -
将 amzn-s3-demo-bucket 替换为发送与此批量导入任务相关的错误的 Amazon S3 存储桶
-for-errors-prefix的前缀。Amazon S3 使用前缀作为文件夹名称来整理存储桶中的数据。每个 Amazon S3 对象都有一个键，作为对象在存储桶中的唯一标识符。桶内的每个对象都只能有一个键。前缀必须以正斜杠（/）结尾。有关更多信息，请参阅 Amazon Simple Storage Service 用户指南中的使用前缀整理对象。
-
将 amzn-s3-demo-bucket 替换为从中导入数据的 Amazon S3 存储桶的
-data名称。 -
data-bucket-key替换为包含您的数据的 Amazon S3 对象的密钥。每个对象都有一个作为唯一标识符的键。每个对象有且只有一个键。 -
data-bucket-version-id替换为版本 ID，以识别包含您的数据的 Amazon S3 对象的特定版本。此参数为可选的。 -
column-name替换为.csv 文件中指定的列名。 -
job-name替换为标识批量导入任务的唯一名称。 -
job-role-arn替换为允许 AWS IoT SiteWise 读取 Amazon S3 数据的 IAM 角色。
注意
确保您的角色具有以下示例中显示的权限。将 amzn-s3-demo-bucket 替换为包含您的数据的 Amazon S3 存储桶的-data名称。此外，请amzn-s3-demo-bucket-for-errors替换为发送与此批量导入任务相关的错误的 Amazon S3 存储桶的名称。
{
"Version": "2012-10-17",
"Statement": [
{
"Action": [
"s3:GetObject",
"s3:GetBucketLocation"
],
"Resource": [
"arn:aws:s3:::amzn-s3-demo-bucket-data",
"arn:aws:s3:::amzn-s3-demo-bucket-data/*",
],
"Effect": "Allow"
},
{
"Action": [
"s3:PutObject",
"s3:GetObject",
"s3:GetBucketLocation"
],
"Resource": [
"arn:aws:s3:::amzn-s3-demo-bucket-for-errors",
"arn:aws:s3:::amzn-s3-demo-bucket-for-errors/*"
],
"Effect": "Allow"
}
]
}{
"adaptiveIngestion": adaptive-ingestion-flag,
"deleteFilesAfterImport": delete-files-after-import-flag,
"errorReportLocation": {
"bucket": "amzn-s3-demo-bucket-for-errors",
"prefix": "amzn-s3-demo-bucket-for-errors-prefix"
},
"files": [
{
"bucket": "amzn-s3-demo-bucket-data",
"key": "data-bucket-key",
"versionId": "data-bucket-version-id"
}
],
"jobConfiguration": {
"fileFormat": {
"csv": {
"columnNames": [ "column-name" ]
}
}
},
"jobName": "job-name",
"jobRoleArn": "job-role-arn"
}例 响应
{
"jobId":"f8c031d0-01d1-4b94-90b1-afe8bb93b7e5",
"jobStatus":"PENDING",
"jobName":"myBulkImportJob"
}