Chilkat Online Tools

DescribePipeline Python Example

AWS IoT Analytics

import sys
import chilkat

# This example requires the Chilkat API to have been previously unlocked.
# See Global Unlock Sample for sample code.

rest = chilkat.CkRest()

authAws = chilkat.CkAuthAws()
authAws.put_AccessKey("AWS_ACCESS_KEY")
authAws.put_SecretKey("AWS_SECRET_KEY")

# Don't forget to change the region to your particular region. (Also make the same change in the call to Connect below.)
authAws.put_Region("us-west-2")
authAws.put_ServiceName("iotanalytics")
# SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
rest.SetAuthAws(authAws)

# URL: https://iotanalytics.us-west-2.amazonaws.com/
# Use the same region as specified above.
success = rest.Connect("iotanalytics.us-west-2.amazonaws.com",443,True,True)
if (success != True):
    print("ConnectFailReason: " + str(rest.get_ConnectFailReason()))
    print(rest.lastErrorText())
    sys.exit()

rest.AddHeader("Content-Type","application/x-amz-json-1.1")
rest.AddHeader("X-Amz-Target","DescribePipeline")

sbResponseBody = chilkat.CkStringBuilder()
success = rest.FullRequestNoBodySb("GET","/pipelines/{pipelineName}",sbResponseBody)
if (success != True):
    print(rest.lastErrorText())
    sys.exit()

respStatusCode = rest.get_ResponseStatusCode()
print("response status code = " + str(respStatusCode))
if (respStatusCode != 200):
    print("Response Header:")
    print(rest.responseHeader())
    print("Response Body:")
    print(sbResponseBody.getAsString())
    sys.exit()

jResp = chilkat.CkJsonObject()
jResp.LoadSb(sbResponseBody)

# The following code parses the JSON response.
# A sample JSON response is shown below the sample code.

# Use this online tool to generate parsing code from sample JSON:
# Generate Parsing Code from JSON

Arn = jResp.stringOf("pipeline.arn")
CreationTime = jResp.IntOf("pipeline.creationTime")
LastUpdateTime = jResp.IntOf("pipeline.lastUpdateTime")
Name = jResp.stringOf("pipeline.name")
i = 0
count_i = jResp.SizeOfArray("pipeline.activities")
while i < count_i :
    jResp.put_I(i)
    v_String = jResp.stringOf("pipeline.activities[i].addAttributes.attributes.string")
    addAttributesName = jResp.stringOf("pipeline.activities[i].addAttributes.name")
    v_Next = jResp.stringOf("pipeline.activities[i].addAttributes.next")
    ChannelName = jResp.stringOf("pipeline.activities[i].channel.channelName")
    channelName = jResp.stringOf("pipeline.activities[i].channel.name")
    channelNext = jResp.stringOf("pipeline.activities[i].channel.next")
    DatastoreName = jResp.stringOf("pipeline.activities[i].datastore.datastoreName")
    datastoreName = jResp.stringOf("pipeline.activities[i].datastore.name")
    Attribute = jResp.stringOf("pipeline.activities[i].deviceRegistryEnrich.attribute")
    deviceRegistryEnrichName = jResp.stringOf("pipeline.activities[i].deviceRegistryEnrich.name")
    deviceRegistryEnrichNext = jResp.stringOf("pipeline.activities[i].deviceRegistryEnrich.next")
    RoleArn = jResp.stringOf("pipeline.activities[i].deviceRegistryEnrich.roleArn")
    ThingName = jResp.stringOf("pipeline.activities[i].deviceRegistryEnrich.thingName")
    deviceShadowEnrichAttribute = jResp.stringOf("pipeline.activities[i].deviceShadowEnrich.attribute")
    deviceShadowEnrichName = jResp.stringOf("pipeline.activities[i].deviceShadowEnrich.name")
    deviceShadowEnrichNext = jResp.stringOf("pipeline.activities[i].deviceShadowEnrich.next")
    deviceShadowEnrichRoleArn = jResp.stringOf("pipeline.activities[i].deviceShadowEnrich.roleArn")
    deviceShadowEnrichThingName = jResp.stringOf("pipeline.activities[i].deviceShadowEnrich.thingName")
    Filter = jResp.stringOf("pipeline.activities[i].filter.filter")
    filterName = jResp.stringOf("pipeline.activities[i].filter.name")
    filterNext = jResp.stringOf("pipeline.activities[i].filter.next")
    BatchSize = jResp.IntOf("pipeline.activities[i].lambda.batchSize")
    LambdaName = jResp.stringOf("pipeline.activities[i].lambda.lambdaName")
    lambdaName = jResp.stringOf("pipeline.activities[i].lambda.name")
    lambdaNext = jResp.stringOf("pipeline.activities[i].lambda.next")
    mathAttribute = jResp.stringOf("pipeline.activities[i].math.attribute")
    Math = jResp.stringOf("pipeline.activities[i].math.math")
    mathName = jResp.stringOf("pipeline.activities[i].math.name")
    mathNext = jResp.stringOf("pipeline.activities[i].math.next")
    removeAttributesName = jResp.stringOf("pipeline.activities[i].removeAttributes.name")
    removeAttributesNext = jResp.stringOf("pipeline.activities[i].removeAttributes.next")
    selectAttributesName = jResp.stringOf("pipeline.activities[i].selectAttributes.name")
    selectAttributesNext = jResp.stringOf("pipeline.activities[i].selectAttributes.next")
    j = 0
    count_j = jResp.SizeOfArray("pipeline.activities[i].removeAttributes.attributes")
    while j < count_j :
        jResp.put_J(j)
        strVal = jResp.stringOf("pipeline.activities[i].removeAttributes.attributes[j]")
        j = j + 1

    j = 0
    count_j = jResp.SizeOfArray("pipeline.activities[i].selectAttributes.attributes")
    while j < count_j :
        jResp.put_J(j)
        strVal = jResp.stringOf("pipeline.activities[i].selectAttributes.attributes[j]")
        j = j + 1

    i = i + 1

i = 0
count_i = jResp.SizeOfArray("pipeline.reprocessingSummaries")
while i < count_i :
    jResp.put_I(i)
    creationTime = jResp.IntOf("pipeline.reprocessingSummaries[i].creationTime")
    id = jResp.stringOf("pipeline.reprocessingSummaries[i].id")
    status = jResp.stringOf("pipeline.reprocessingSummaries[i].status")
    i = i + 1

# A sample JSON response body parsed by the above code:

# {
#   "pipeline": {
#     "activities": [
#       {
#         "addAttributes": {
#           "attributes": {
#             "string": "string"
#           },
#           "name": "string",
#           "next": "string"
#         },
#         "channel": {
#           "channelName": "string",
#           "name": "string",
#           "next": "string"
#         },
#         "datastore": {
#           "datastoreName": "string",
#           "name": "string"
#         },
#         "deviceRegistryEnrich": {
#           "attribute": "string",
#           "name": "string",
#           "next": "string",
#           "roleArn": "string",
#           "thingName": "string"
#         },
#         "deviceShadowEnrich": {
#           "attribute": "string",
#           "name": "string",
#           "next": "string",
#           "roleArn": "string",
#           "thingName": "string"
#         },
#         "filter": {
#           "filter": "string",
#           "name": "string",
#           "next": "string"
#         },
#         "lambda": {
#           "batchSize": number,
#           "lambdaName": "string",
#           "name": "string",
#           "next": "string"
#         },
#         "math": {
#           "attribute": "string",
#           "math": "string",
#           "name": "string",
#           "next": "string"
#         },
#         "removeAttributes": {
#           "attributes": [
#             "string"
#           ],
#           "name": "string",
#           "next": "string"
#         },
#         "selectAttributes": {
#           "attributes": [
#             "string"
#           ],
#           "name": "string",
#           "next": "string"
#         }
#       }
#     ],
#     "arn": "string",
#     "creationTime": number,
#     "lastUpdateTime": number,
#     "name": "string",
#     "reprocessingSummaries": [
#       {
#         "creationTime": number,
#         "id": "string",
#         "status": "string"
#       }
#     ]
#   }
# }