AWS IoT SiteWise

Technical Preview

Overview

A client-mode connector for a curated cloud-IoT slice of AWS IoT SiteWise covering property ingest from UNS topics, property history queries, and asset create from Sparkplug birth:

Catalog connector event	Entity / path	Notes
POST properties batch put	`POST /properties`	Data-plane BatchPutAssetPropertyValue
GET property history	`GET /properties/history`	Data-plane GetAssetPropertyValueHistory
POST assets create (Sparkplug birth)	`POST /assets`	Control-plane CreateAsset — switch BASE to `api.iotsitewise`
GET ListAssets (auth smoke)	`GET /assets`	Control-plane ListAssets — switch BASE to `api.iotsitewise`

Default BASE_ADDRESS is data-plane https://data.iotsitewise.eu-west-1.amazonaws.com (no trailing slash; substitute {region}). Topics use cloud-iot/aws-iot-sitewise/<object>/<verb>. See the base guide: REST API Connectors.

Control-plane ops: set BASE_ADDRESS to https://api.iotsitewise.{region}.amazonaws.com for CreateAsset and ListAssets. SigV4 service name on both planes is iotsitewise.

Data-plane SigV4: Pass Authorization, x-amz-date, and x-amz-content-sha256 from an upstream signer via MQTT JSON placeholders. Prefer Hub secrets for AWS keys — never commit them into the .lot.

Prefer Hub secrets for AWS keys used by an upstream SigV4 signer. This template has not been verified against a live AWS account. Status remains blocked until an authenticated live smoke succeeds.

Basic Syntax

# Coreflux REST_API template — AWS IoT SiteWise curated slice
# Auth: SigV4 via {value.json.authorization}, {value.json.x_amz_date},
#       {value.json.x_amz_content_sha256}
# BASE_ADDRESS: https://data.iotsitewise.eu-west-1.amazonaws.com (data plane)

DEFINE ROUTE AwsIotSitewiseRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://data.iotsitewise.eu-west-1.amazonaws.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT BatchPutAssetPropertyValue
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/properties/batch-put"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/properties/batch-put/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/properties"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
        WITH BODY "{payload}"
    ADD EVENT GetAssetPropertyValueHistory
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/properties/history"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/properties/history/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/properties/history?propertyAlias={value.json.property_alias}&startDate={value.json.start_date}&endDate={value.json.end_date}&maxResults={value.json.max_results}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
    ADD EVENT CreateAsset
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/assets/create"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/assets/create/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/assets"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
        WITH BODY "{payload}"
    ADD EVENT ListAssets
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/assets/list"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/assets/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/assets?filter={value.json.filter}&maxResults={value.json.max_results}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"

Configuration

Setting	Value
Connector name	`AwsIotSitewiseRestApi`
Type	`REST_API` (client)
BASE_ADDRESS	`https://data.iotsitewise.eu-west-1.amazonaws.com` (data plane; change region as needed)
Topic prefix	`cloud-iot/aws-iot-sitewise/...`
Default Content-Type	`application/json`
Auth	SigV4 headers from MQTT placeholders (service `iotsitewise`)
Status	Technical preview — needs AWS keys + region

MQTT topics

Event	Source	Response
BatchPutAssetPropertyValue	`cloud-iot/aws-iot-sitewise/properties/batch-put`	`.../properties/batch-put/response`
GetAssetPropertyValueHistory	`cloud-iot/aws-iot-sitewise/properties/history`	`.../properties/history/response`
CreateAsset	`cloud-iot/aws-iot-sitewise/assets/create`	`.../assets/create/response`
ListAssets	`cloud-iot/aws-iot-sitewise/assets/list`	`.../assets/list/response`

Auth details

Sign each request with AWS Signature Version 4 using service name iotsitewise (both planes).
Map signed values into MQTT JSON: authorization, x_amz_date, x_amz_content_sha256 (and optional STS session token).
Store AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY as Hub secrets for the upstream signer — never in the deployable .lot.
Use data-plane BASE for BatchPut / history; switch to control-plane BASE (api.iotsitewise.{region}.amazonaws.com) for CreateAsset / ListAssets.

REST API Connectors
AWS IoT Core (same SigV4 placeholder pattern)
Amazon S3 (same SigV4 placeholder pattern)
BatchPutAssetPropertyValue
GetAssetPropertyValueHistory
CreateAsset
ListAssets
SiteWise endpoints

Quick Start

Coreflux MQTT Broker

LoT Language

Coreflux HUB

VS Code - LoT Notebooks

Coreflux Portal

Using AI with Coreflux

Product Updates

Overview

Basic Syntax

Configuration

MQTT topics

Auth details

​Overview

​Basic Syntax

​Configuration

​MQTT topics

​Auth details

​Related

Overview

Basic Syntax

Configuration

MQTT topics

Auth details

Related