Upload Attributes¶
Upload the attribute data of a device or logic asset, including file-type data.
Operation Permissions¶
Required Authorization |
Required Operation Permission |
---|---|
Asset |
Write |
Request Format¶
POST https://{integration-address}/connect-service/v2.1/integration?action=postAttribute
Note
{integration-address}:The gateway address of message integration service. Log in to the EnOS Management Console and find it in Help > Environment Information .
Request Parameters(URI)¶
Name |
Location (Path/Query) |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|---|
orgId |
Query |
Mandatory |
String |
The organization ID which the asset belongs to. How to get orgId>> |
Request Parameters (Header)¶
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
apim-accesstoken |
Mandatory |
String |
The access token obtained via token authentication. For more information, see Get Access Token |
Request Parameters (Body)¶
The format of the request body is multipart/form-data, consisting of multiple form-data sections. For a request body:
There must only be one request message. The request message takes up the space of one form-data and its format is “request form-data”. The header and body of the “request form-data” are shown in the tables below.
There can be one or multiple file form-data. If a request body contains file data, one file takes up the space of one file form-data. Its format is “file form-data”. The header of a “file form-data” is shown in the table below. If the body does not contain any file data, the body does not have to contain any file form-data.
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
Content-Disposition |
Mandatory |
Content-Disposition: form-data; name=”enos-message” |
|
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
method |
Mandatory |
String |
The request method. |
id |
Mandatory |
Integer |
The request message ID. |
version |
Mandatory |
String |
The version number |
params |
Mandatory |
Array of Attribute Structs |
An array of Attribute Structs. See the table below for the structure of an Attribute Struct. |
files |
Mandatory |
Map |
The mapping between files and asset attributes. Its value is a key-value pair |
Note
Use one of the following methods to specify the device:
Include the
assetId
in the RequestInclude both
productKey
+deviceKey
in the Request
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
assetId |
Optional (See Note above) |
String |
The asset ID. How to get assetID>> |
productKey |
Optional (See Note above) |
String |
The product key. To be used with |
deviceKey |
Optional (See Note above) |
String |
The device key. To be used with |
attributes |
Mandatory |
Map |
The format used is a key-value pair |
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
featureId |
Mandatory |
String |
The measurement point ID. |
assetId |
Optional |
String |
The asset ID. |
productKey |
Optional |
String |
The product key of the asset. |
deviceKey |
Optional |
String |
The device key of the asset. |
md5 |
Optional |
String |
The MD5 of the file. |
originalFilename |
Optional |
String |
The name of the file, which will be returned when downloading. If not specified, the filename will be randomly generated. |
fileExt |
Optional |
String |
The filename extension, such as .zip and .gpg. |
fileLength |
Optional |
Long |
The size of the file in bytes. The size used will be the value of |
Name |
Mandatory/Optional |
Data Type |
Description |
---|---|---|---|
Content-Disposition |
Mandatory |
Content-Disposition: form-data; name=”enos-file”; filename=”yourFileName”; feature-type=”attribute”; feature-id=”xxx”;asset-id=”xxx”;product-key=”xxx”;device-key=”xxx” |
Fixed parameter in the file form-data. Fields are separated by a semicolon (;). |
Content-Length |
Mandatory |
Long |
The size of the file in bytes. |
Response Parameters¶
Name |
Data Type |
Description |
---|---|---|
code |
Integer |
Return code of a request.
+ |
msg |
String |
The explanation to the return code. Its value is |
requestId |
String |
A unique ID to identify a request. |
Samples¶
Request Sample¶
url: https://{apigw-address}/connect-service/v2.1/integration?action=postAttribute&orgId=yourOrgId
method: POST
requestHeader:
{
"apim-accesstoken":"yourAccessToken"
}
requestBody:
Request message form-data
Content-Disposition: form-data; name="enos-message"
{
"method": "integration.attibute.post",
"id": "123",
"version": "1.1",
"params":[
{
"productKey": "productKey1",
"deviceKey": "deviceKey1",
"attributes": {
"intAttibuteId1": 123,
"fileAttibuteId1":"local://filename1"
}
},
{
"assetId": "assetId2",
"attributes": {
"intAttibuteId2": 123,
"fileAttibuteId2": "local://filename2"
}
}
],
"files": {
"filename1": {
"featureId": "fileAttibuteId1",
"produckKey": "productKey1",
"deviceKey": "deviceKey1",
"originalFilename": "file.txt",
"fileExt": ".txt",
"md5": "0e202f9b67323d11df8a79b319a3d4f6"
},
"filename2": {
"featureId": "fileAttibuteId2",
"assetId": "assetId2",
"md5": "aa8ea05bdbcbadfcda7300c65c40859f",
"fileLength": 1024000
}
}
}
File form-data
Content-Disposition: form-data; name="enos-file"; filename="filename1"; Content-Length: 1024000
<Content of file filename1>
File form-data
Content-Disposition: form-data; name="enos-file"; filename="filename2"; Content-Length: 1024000
<Content of file filename2>
Response Sample¶
{
"code":0,
"msg":"OK",
"requestId":"861bb9f0-f9db-4adf-bf5e-976e6943338e",
"data":{}
}
Java SDK Sample¶
import com.envisioniot.enos.iot_http_integration.HttpConnection;
import com.envisioniot.enos.iot_http_integration.message.IIntegrationCallback;
import com.envisioniot.enos.iot_http_integration.message.IntegrationAttributePostRequest;
import com.envisioniot.enos.iot_http_integration.message.IntegrationResponse;
import com.envisioniot.enos.iot_mqtt_sdk.core.exception.EnvisionException;
import com.envisioniot.enos.sdk.data.DeviceInfo;
import com.google.common.collect.Maps;
import com.google.gson.GsonBuilder;
import java.io.File;
import java.io.IOException;
import java.util.HashMap;
public class AttributeIntegrationSample {
// EnOS Token Server URL and HTTP Broker URL, which can be obtained from Environment Information page in EnOS Console
static final String TOKEN_SERVER_URL = "http://token_server_url";
static final String BROKER_URL = "http://broker_url";
// EnOS Application AccessKey and SecretKey, which can be obtain in Application Registration page in EnOS Console
static final String APP_KEY = "appKey";
static final String APP_SECRET = "appSecret";
// Device credentials, which can be obtained from Device Details page in EnOS Console
static final String ORG_ID = "orgId";
static final String ASSET_ID = "assetId";
static final String PRODUCT_KEY = "productKey";
static final String DEVICE_KEY = "deviceKey";
private static IntegrationAttributePostRequest buildAttributePostRequest() {
DeviceInfo deviceInfo1 = new DeviceInfo().setAssetId(ASSET_ID);
DeviceInfo deviceInfo2 = new DeviceInfo().setKey(PRODUCT_KEY, DEVICE_KEY);
// Attributes are defined in ThingModel
// FileAttribute1 is a file-type attribute
HashMap < String, Object > hashMap = Maps.newHashMap();
hashMap.put("IntAttribute1", 123);
hashMap.put("FileAttribute1", new File("sample1.txt"));
return IntegrationAttributePostRequest.builder()
.addAttribute(deviceInfo1, hashMap)
.addAttribute(deviceInfo2, hashMap)
.build();
}
public static void main(String[] args) {
// Construct a http connection
HttpConnection connection = new HttpConnection.Builder(
BROKER_URL, TOKEN_SERVER_URL, APP_KEY, APP_SECRET, ORG_ID)
.build();
IntegrationAttributePostRequest request = buildAttributePostRequest();
try {
IntegrationResponse response = connection.publish(request, (bytes, length) ->
System.out.println(String.format("Progress: %.2f %%", (float) bytes / length * 100.0)));
System.out.println(new GsonBuilder().setPrettyPrinting().create().toJson(response));
} catch (EnvisionException | IOException e) {
e.printStackTrace();
}
// Asynchronously call the attribute post with file
request = buildAttributePostRequest();
try {
connection.publish(request, new IIntegrationCallback() {
@Override
public void onResponse(IntegrationResponse response) {
System.out.println("receive response asynchronously");
System.out.println(new GsonBuilder().setPrettyPrinting().create().toJson(response));
}
@Override
public void onFailure(Exception failure) {
failure.printStackTrace();
}
}, (bytes, length) ->
System.out.println(String.format("Progress: %.2f %%", (float) bytes / length * 100.0))
);
} catch (IOException | EnvisionException e) {
e.printStackTrace();
}
}
}