Ingesting data using the CreateBulkImportJob API
You can use the CreateBulkImportJob
API to import large amounts of data from Amazon S3.
Your data must be saved in the CSV format in Amazon S3. Data files can have the following columns.
Note
To identify an asset property, you can specify one of the following.
-
The
ASSET_ID
andPROPERTY_ID
of the asset property that you you're sending data to. -
The
ALIAS
, which is a data stream alias (for example,/company/windfarm/3/turbine/7/temperature
). To use this option, you must first set your asset property's alias. To learn how to set property aliases, see Mapping industrial data streams to asset properties.
-
ALIAS
– The alias that identifies the property, such as an OPC-UA server data stream path (for example,/company/windfarm/3/turbine/7/temperature
). For more information, see Mapping industrial data streams to asset properties. -
ASSET_ID
– The ID of the asset. -
PROPERTY_ID
– The ID of the asset property. -
DATA_TYPE
– The property's data type can be one of the following.-
STRING
– A string with up to 1024 bytes. -
INTEGER
– A floating point number with range [-10^100, 10^100] and IEEE 754 double precision. -
DOUBLE
– A signed 32-bit integer with range [-2,147,483,648, 2,147,483,647]. -
BOOLEAN
–true
orfalse
.
-
-
TIMESTAMP_SECONDS
– The timestamp of the data point, in Unix epoch time. -
TIMESTAMP_NANO_OFFSET
– The nanosecond offset coverted fromTIMESTAMP_SECONDS
. -
QUALITY
– (Optional) The quality of the asset property value. The value can be one of the following.-
GOOD
– (Default) The data isn't affected by any issues. -
BAD
– The data is affected by an issue such as sensor failure. -
UNCERTAIN
– The data is affected by an issue such as sensor inaccuracy.
For more information about how AWS IoT SiteWise handles data quality in computations, see Data quality in formula expressions.
-
-
VALUE
– The value of the asset property.
Example data file(s) in the .csv format
asset_id,property_id,DOUBLE,1635201373,0,GOOD,1.0 asset_id,property_id,DOUBLE,1635201374,0,GOOD,2.0 asset_id,property_id,DOUBLE,1635201375,0,GOOD,3.0
unmodeled_alias1,DOUBLE,1635201373,0,GOOD,1.0 unmodeled_alias1,DOUBLE,1635201374,0,GOOD,2.0 aunmodeled_alias1,DOUBLE,1635201375,0,GOOD,3.0 unmodeled_alias1,DOUBLE,1635201376,0,GOOD,4.0 unmodeled_alias1,DOUBLE,1635201377,0,GOOD,5.0 unmodeled_alias1,DOUBLE,1635201378,0,GOOD,6.0 unmodeled_alias1,DOUBLE,1635201379,0,GOOD,7.0 unmodeled_alias1,DOUBLE,1635201380,0,GOOD,8.0 unmodeled_alias1,DOUBLE,1635201381,0,GOOD,9.0 unmodeled_alias1,DOUBLE,1635201382,0,GOOD,10.0
AWS IoT SiteWise provides the following API operations that you can use to create a bulk import job and get information about an existing job.
-
CreateBulkImportJob – Creates a new bulk import job.
-
DescribeBulkImportJob – Retrieves information about a bulk import job.
-
ListBulkImportJob – Retrieves a paginated list of summaries of all bulk import jobs.