Siemens Insights Hub

# Coreflux REST_API template — Siemens Insights Hub curated slice
# Auth: Authorization via {value.json.authorization} (Bearer …)
# BASE_ADDRESS: https://gateway.eu1.mindsphere.io/api  → substitute {region}

DEFINE CONNECTOR SiemensInsightsHubRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://gateway.eu1.mindsphere.io/api"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT PutTimeseries
        WITH SOURCE_TOPIC "cloud-iot/siemens-insights-hub/timeseries/put"
        WITH DESTINATION_TOPIC "cloud-iot/siemens-insights-hub/timeseries/put/response"
        WITH METHOD "PUT"
        WITH ENDPOINT "/iottimeseries/v3/timeseries/{value.json.assetId}/{value.json.aspectName}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
        WITH BODY "{payload}"
    ADD EVENT GetTimeseries
        WITH SOURCE_TOPIC "cloud-iot/siemens-insights-hub/timeseries/get"
        WITH DESTINATION_TOPIC "cloud-iot/siemens-insights-hub/timeseries/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/iottimeseries/v3/timeseries/{value.json.assetId}/{value.json.aspectName}?from={value.json.from}&to={value.json.to}&limit={value.json.limit}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
    ADD EVENT CreateEvent
        WITH SOURCE_TOPIC "cloud-iot/siemens-insights-hub/event/create"
        WITH DESTINATION_TOPIC "cloud-iot/siemens-insights-hub/event/create/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/eventmanagement/v3/events"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
        WITH BODY "{payload}"
    ADD EVENT ListAssets
        WITH SOURCE_TOPIC "cloud-iot/siemens-insights-hub/asset/list"
        WITH DESTINATION_TOPIC "cloud-iot/siemens-insights-hub/asset/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/assetmanagement/v3/assets?page={value.json.page}&size={value.json.size}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
    ADD EVENT ListEvents
        WITH SOURCE_TOPIC "cloud-iot/siemens-insights-hub/event/list"
        WITH DESTINATION_TOPIC "cloud-iot/siemens-insights-hub/event/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/eventmanagement/v3/events?page={value.json.page}&size={value.json.size}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"