AWS IoT Analytics esempi utilizzando AWS CLI

Per inviare un messaggio a un canale

L'batch-put-messageesempio seguente invia un messaggio al canale specificato.

aws iotanalytics batch-put-message \
    --cli-binary-format raw-in-base64-out \
    --cli-input-json file://batch-put-message.json

Contenuto di batch-put-message.json.

{
    "channelName": "mychannel",
    "messages": [
        {
            "messageId": "0001",
            "payload": "eyAidGVtcGVyYXR1cmUiOiAyMCB9"
        }
    ]
}

Output:

{
    "batchPutMessageErrorEntries": []
}

Per ulteriori informazioni, BatchPutMessageconsulta AWS IoT Analytics API Reference.

Per annullare la rielaborazione dei dati tramite una pipeline

L'cancel-pipeline-reprocessingesempio seguente annulla la rielaborazione dei dati tramite la pipeline specificata.

aws iotanalytics cancel-pipeline-reprocessing \
    --pipeline-name mypipeline \
    --reprocessing-id "6ad2764f-fb13-4de3-b101-4e74af03b043"

Questo comando non produce alcun output.

Per ulteriori informazioni, CancelPipelineReprocessingconsulta AWS IoT Analytics API Reference.

Per creare un canale

L'create-channelesempio seguente crea un canale con la configurazione specificata. Un canale raccoglie dati da un MQTT argomento e archivia i messaggi non elaborati e non elaborati prima di pubblicarli in una pipeline.

aws iotanalytics create-channel \
    --cli-input-json file://create-channel.json

Contenuto di create-channel.json.

{
    "channelName": "mychannel",
    "retentionPeriod": {
        "unlimited": true
    },
    "tags": [
        {
            "key": "Environment",
            "value": "Production"
        }
    ]
}

Output:

{
    "channelArn": "arn:aws:iotanalytics:us-west-2:123456789012:channel/mychannel",
    "channelName": "mychannel",
    "retentionPeriod": {
        "unlimited": true
    }
}

Per ulteriori informazioni, CreateChannelconsulta AWS IoT Analytics API Reference.

Per creare il contenuto di un set di dati

L'create-dataset-contentesempio seguente crea il contenuto del set di dati specificato applicando a queryAction (una SQL query) o a containerAction (eseguendo un'applicazione containerizzata).

aws iotanalytics create-dataset-content \
    --dataset-name mydataset

Output:

{
    "versionId": "d494b416-9850-4670-b885-ca22f1e89d62"
}

Per ulteriori informazioni, CreateDatasetContentconsulta AWS IoT Analytics API Reference.

Per creare un set di dati

L'create-datasetesempio seguente crea un set di dati. Un set di dati memorizza i dati recuperati da un data store applicando a queryAction (una SQL query) o a containerAction (eseguendo un'applicazione containerizzata). Questa operazione crea lo scheletro di un set di dati. È possibile popolare il set di dati manualmente chiamando CreateDatasetContent o automaticamente in base a una specifica. trigger

aws iotanalytics create-dataset \
    --cli-input-json file://create-dataset.json

Contenuto di create-dataset.json.

{
    "datasetName": "mydataset",
    "actions": [
        {
            "actionName": "myDatasetAction",
            "queryAction": {
                "sqlQuery": "SELECT * FROM mydatastore"
            }
        }
    ],
    "retentionPeriod": {
        "unlimited": true
    },
    "tags": [
        {
            "key": "Environment",
            "value": "Production"
        }
    ]
}

Output:

{
    "datasetName": "mydataset",
    "retentionPeriod": {
        "unlimited": true
    },
    "datasetArn": "arn:aws:iotanalytics:us-west-2:123456789012:dataset/mydataset"
}

Per ulteriori informazioni, CreateDatasetconsulta AWS IoT Analytics API Reference.

Per creare un archivio dati

L'create-datastoreesempio seguente crea un data store, che è un archivio per i messaggi.

aws iotanalytics create-datastore \
    --cli-input-json file://create-datastore.json

Contenuto di create-datastore.json.

{
    "datastoreName": "mydatastore",
    "retentionPeriod": {
        "numberOfDays": 90
    },
    "tags": [
        {
            "key": "Environment",
            "value": "Production"
        }
    ]
}

Output:

{
    "datastoreName": "mydatastore",
    "datastoreArn": "arn:aws:iotanalytics:us-west-2:123456789012:datastore/mydatastore",
    "retentionPeriod": {
        "numberOfDays": 90,
        "unlimited": false
    }
}

Per ulteriori informazioni, CreateDatastoreconsulta AWS IoT Analytics API Reference.

Crea una pipeline IoT Analytics

L'create-pipelineesempio seguente crea una pipeline. Una pipeline utilizza i messaggi provenienti da un canale e permette di elaborarli prima di archiviarli in un datastore. È necessario specificare sia un canale che un'attività di archivio dati e, facoltativamente, fino a 23 attività aggiuntive nell'pipelineActivitiesarray.

aws iotanalytics create-pipeline \
    --cli-input-json file://create-pipeline.json

Contenuto di create-pipeline.json.

{
    "pipelineName": "mypipeline",
    "pipelineActivities": [
        {
            "channel": {
                "name": "myChannelActivity",
                "channelName": "mychannel",
                "next": "myMathActivity"
            }
        },
        {
            "datastore": {
                "name": "myDatastoreActivity",
                "datastoreName": "mydatastore"
            }
        },
        {
            "math": {
                "name": "myMathActivity",
                "math": "((temp - 32) * 5.0) / 9.0",
                "attribute": "tempC",
                "next": "myDatastoreActivity"
            }
        }
    ],
    "tags": [
        {
            "key": "Environment",
            "value": "Beta"
        }
    ]
}

Output:

{
    "pipelineArn": "arn:aws:iotanalytics:us-west-2:123456789012:pipeline/mypipeline",
    "pipelineName": "mypipeline"
}

Per ulteriori informazioni, CreatePipelineconsulta AWS IoT Analytics API Reference.

Eliminare un canale IoT Analytics

L'delete-channelesempio seguente elimina il canale specificato.

aws iotanalytics delete-channel \
    --channel-name mychannel

Questo comando non produce alcun output.

Per ulteriori informazioni, DeleteChannelconsulta AWS IoT Analytics API Reference.

Per eliminare il contenuto del set di dati

L'delete-dataset-contentesempio seguente elimina il contenuto del set di dati specificato.

aws iotanalytics delete-dataset-content \
    --dataset-name mydataset

Questo comando non produce alcun output.

Per ulteriori informazioni, DeleteDatasetContentconsulta AWS IoT Analytics API Reference.

Per eliminare un set di dati

L'delete-datasetesempio seguente elimina il set di dati specificato. Non è necessario eliminare il contenuto del set di dati prima di eseguire questa operazione.

aws iotanalytics delete-dataset \
    --dataset-name mydataset

Questo comando non produce alcun output.

Per ulteriori informazioni, DeleteDatasetconsulta AWS IoT Analytics API Reference.

Per eliminare un archivio dati

L'delete-datastoreesempio seguente elimina l'archivio dati specificato.

aws iotanalytics delete-datastore \
    --datastore-name mydatastore

Questo comando non produce alcun output.

Per ulteriori informazioni, DeleteDatastoreconsulta AWS IoT Analytics API Reference.

Per eliminare una pipeline

L'delete-pipelineesempio seguente elimina la tubazione specificata.

aws iotanalytics delete-pipeline \
    --pipeline-name mypipeline

Questo comando non produce alcun output.

Per ulteriori informazioni, DeletePipelineconsulta AWS IoT Analytics API Reference.

Per recuperare informazioni su un canale

L'describe-channelesempio seguente visualizza i dettagli, incluse le statistiche, per il canale specificato.

aws iotanalytics describe-channel \
    --channel-name mychannel \
    --include-statistics

Output:

{
    "statistics": {
        "size": {
            "estimatedSizeInBytes": 402.0,
            "estimatedOn": 1561504380.0
        }
    },
    "channel": {
        "status": "ACTIVE",
        "name": "mychannel",
        "lastUpdateTime": 1557860351.001,
        "creationTime": 1557860351.001,
        "retentionPeriod": {
            "unlimited": true
        },
        "arn": "arn:aws:iotanalytics:us-west-2:123456789012:channel/mychannel"
    }
}

Per ulteriori informazioni, DescribeChannelconsulta AWS IoT Analytics API Reference.

Per recuperare informazioni su un set di dati

L'describe-datasetesempio seguente visualizza i dettagli per il set di dati specificato.

aws iotanalytics describe-dataset \
    --dataset-name mydataset

Output:

{
    "dataset": {
        "status": "ACTIVE",
        "contentDeliveryRules": [],
        "name": "mydataset",
        "lastUpdateTime": 1557859240.658,
        "triggers": [],
        "creationTime": 1557859240.658,
        "actions": [
            {
                "actionName": "query_32",
                "queryAction": {
                    "sqlQuery": "SELECT * FROM mydatastore",
                    "filters": []
                }
            }
        ],
        "retentionPeriod": {
            "numberOfDays": 90,
            "unlimited": false
        },
        "arn": "arn:aws:iotanalytics:us-west-2:123456789012:dataset/mydataset"
    }
}

Per ulteriori informazioni, DescribeDatasetconsulta AWS IoT Analytics API Reference.

Per recuperare informazioni su un archivio dati

L'describe-datastoreesempio seguente visualizza i dettagli, incluse le statistiche, per il data store specificato.

aws iotanalytics describe-datastore \
    --datastore-name mydatastore \
    --include-statistics

Output:

{
    "datastore": {
        "status": "ACTIVE",
        "name": "mydatastore",
        "lastUpdateTime": 1557858971.02,
        "creationTime": 1557858971.02,
        "retentionPeriod": {
            "unlimited": true
        },
        "arn": "arn:aws:iotanalytics:us-west-2:123456789012:datastore/mydatastore"
    },
    "statistics": {
        "size": {
            "estimatedSizeInBytes": 397.0,
            "estimatedOn": 1561592040.0
        }
    }
}

Per ulteriori informazioni, DescribeDatastoreconsulta AWS IoT Analytics API Reference.

Per recuperare le opzioni di registrazione correnti

L'describe-logging-optionsesempio seguente mostra le opzioni di registrazione correnti di AWS IoT Analytics.

aws iotanalytics describe-logging-options

Questo comando non produce alcun output. Output:

{
    "loggingOptions": {
        "roleArn": "arn:aws:iam::123456789012:role/service-role/myIoTAnalyticsRole",
        "enabled": true,
        "level": "ERROR"
    }
}

Per ulteriori informazioni, DescribeLoggingOptionsconsulta AWS IoT Analytics API Reference.

Per recuperare informazioni su una pipeline

L'describe-pipelineesempio seguente visualizza i dettagli della tubazione specificata.

aws iotanalytics describe-pipeline \
    --pipeline-name mypipeline

Output:

{
    "pipeline": {
        "activities": [
            {
                "channel": {
                    "channelName": "mychannel",
                    "name": "mychannel_28",
                    "next": "mydatastore_29"
                }
            },
            {
                "datastore": {
                    "datastoreName": "mydatastore",
                    "name": "mydatastore_29"
                }
            }
        ],
        "name": "mypipeline",
        "lastUpdateTime": 1561676362.515,
        "creationTime": 1557859124.432,
        "reprocessingSummaries": [
            {
                "status": "SUCCEEDED",
                "creationTime": 1561676362.189,
                "id": "6ad2764f-fb13-4de3-b101-4e74af03b043"
            }
        ],
        "arn": "arn:aws:iotanalytics:us-west-2:123456789012:pipeline/mypipeline"
    }
}

Per ulteriori informazioni, DescribePipelineconsulta AWS IoT Analytics API Reference.

Per recuperare il contenuto di un set di dati

L'get-dataset-contentesempio seguente recupera il contenuto di un set di dati come predefinito. URIs

aws iotanalytics get-dataset-content --dataset-name mydataset

Output:

{
    "status": {
        "state": "SUCCEEDED"
    },
    "timestamp": 1557863215.995,
    "entries": [
        {
            "dataURI": "https://aws-radiant-dataset-12345678-1234-1234-1234-123456789012.s3.us-west-2.amazonaws.com/results/12345678-e8b3-46ba-b2dd-efe8d86cf385.csv?X-Amz-Security-Token=...-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Date=20190628T173437Z&X-Amz-SignedHeaders=host&X-Amz-Expires=7200&X-Amz-Credential=...F20190628%2Fus-west-2%2Fs3%2Faws4_request&X-Amz-Signature=..."
        }
    ]
}

Per ulteriori informazioni, consulta la guida GetDatasetContent.

Per recuperare un elenco di canali

L'list-channelsesempio seguente visualizza informazioni di riepilogo per i canali disponibili.

aws iotanalytics list-channels

Output:

{
    "channelSummaries": [
        {
            "status": "ACTIVE",
            "channelName": "mychannel",
            "creationTime": 1557860351.001,
            "lastUpdateTime": 1557860351.001
        }
    ]
}

Per ulteriori informazioni, ListChannelsconsulta AWS IoT Analytics API Reference.

Per elencare informazioni sul contenuto del set di dati

L'list-dataset-contentsesempio seguente elenca le informazioni sui contenuti dei set di dati che sono stati creati.

aws iotanalytics list-dataset-contents \
    --dataset-name mydataset

Output:

{
    "datasetContentSummaries": [
        {
            "status": {
                "state": "SUCCEEDED"
            },
            "scheduleTime": 1557863215.995,
            "version": "b10ea2a9-66c1-4d99-8d1f-518113b738d0",
            "creationTime": 1557863215.995
        }
    ]
}

Per ulteriori informazioni, ListDatasetContentsconsulta AWS IoT Analytics API Reference.

Per recuperare informazioni sui set di dati

L'list-datasetsesempio seguente elenca informazioni di riepilogo sui set di dati disponibili.

aws iotanalytics list-datasets

Output:

{
    "datasetSummaries": [
        {
            "status": "ACTIVE",
            "datasetName": "mydataset",
            "lastUpdateTime": 1557859240.658,
            "triggers": [],
            "creationTime": 1557859240.658,
            "actions": [
                {
                    "actionName": "query_32",
                    "actionType": "QUERY"
                }
            ]
        }
    ]
}

Per ulteriori informazioni, ListDatasetsconsulta AWS IoT Analytics API Reference.

Per recuperare un elenco di archivi dati

L'list-datastoresesempio seguente visualizza informazioni di riepilogo sugli archivi dati disponibili.

aws iotanalytics list-datastores

Output:

{
    "datastoreSummaries": [
        {
            "status": "ACTIVE",
            "datastoreName": "mydatastore",
            "creationTime": 1557858971.02,
            "lastUpdateTime": 1557858971.02
        }
    ]
}

Per ulteriori informazioni, ListDatastoresconsulta AWS IoT Analytics API Reference.

Per recuperare un elenco di pipeline

L'list-pipelinesesempio seguente visualizza un elenco di tubazioni disponibili.

aws iotanalytics list-pipelines

Output:

{
    "pipelineSummaries": [
        {
            "pipelineName": "mypipeline",
            "creationTime": 1557859124.432,
            "lastUpdateTime": 1557859124.432,
            "reprocessingSummaries": []
        }
    ]
}

Per ulteriori informazioni, ListPipelinesconsulta AWS IoT Analytics API Reference.

Per elencare i tag di una risorsa

L'list-tags-for-resourceesempio seguente elenca i tag che avete allegato alla risorsa specificata.

aws iotanalytics list-tags-for-resource \
    --resource-arn "arn:aws:iotanalytics:us-west-2:123456789012:channel/mychannel"

Output:

{
    "tags": [
        {
            "value": "bar",
            "key": "foo"
        }
    ]
}

Per ulteriori informazioni, ListTagsForResourceconsulta AWS IoT Analytics API Reference.

Per impostare o aggiornare le opzioni di registrazione

L'put-logging-optionsesempio seguente imposta o aggiorna le opzioni di registrazione di AWS IoT Analytics. Se aggiorni il valore di un loggingOptions campo, può essere necessario fino a un minuto prima che la modifica abbia effetto. Inoltre, se modifichi la politica associata al ruolo specificato nel campo "roleArn" (ad esempio, per correggere una politica non valida), possono essere necessari fino a cinque minuti prima che la modifica abbia effetto.

aws iotanalytics put-logging-options \
    --cli-input-json file://put-logging-options.json

Contenuto di put-logging-options.json.

{
    "loggingOptions": {
        "roleArn": "arn:aws:iam::123456789012:role/service-role/myIoTAnalyticsRole",
        "level": "ERROR",
        "enabled": true
    }
}

Questo comando non produce alcun output.

Per ulteriori informazioni, PutLoggingOptionsconsulta AWS IoT Analytics API Reference.

Per simulare un'attività di pipeline

L'run-pipeline-activityesempio seguente simula i risultati dell'esecuzione di un'attività di pipeline su un payload di messaggi.

aws iotanalytics run-pipeline-activity \
    --pipeline-activity file://maths.json \
    --payloads file://payloads.json

Contenuto di maths.json.

{
    "math": {
        "name": "MyMathActivity",
        "math": "((temp - 32) * 5.0) / 9.0",
        "attribute": "tempC"
    }
}

Contenuto di payloads.json.

[
    "{\"humidity\": 52, \"temp\": 68 }",
    "{\"humidity\": 52, \"temp\": 32 }"
]

Output:

{
    "logResult": "",
    "payloads": [
        "eyJodW1pZGl0eSI6NTIsInRlbXAiOjY4LCJ0ZW1wQyI6MjB9",
        "eyJodW1pZGl0eSI6NTIsInRlbXAiOjMyLCJ0ZW1wQyI6MH0="
    ]
}

Per ulteriori informazioni, RunPipelineActivityconsulta AWS IoT Analytics API Reference.

Per recuperare messaggi di esempio da un canale

L'sample-channel-dataesempio seguente recupera un campione di messaggi dal canale specificato importati durante il periodo di tempo specificato. È possibile recuperare fino a 10 messaggi.

aws iotanalytics sample-channel-data \
    --channel-name mychannel

Output:

{
    "payloads": [
        "eyAidGVtcGVyYXR1cmUiOiAyMCB9",
        "eyAiZm9vIjogImJhciIgfQ=="
    ]
}

Per ulteriori informazioni, SampleChannelDataconsulta AWS IoT Analytics API Reference.

Per avviare la rielaborazione della pipeline

L'start-pipeline-reprocessingesempio seguente avvia la rielaborazione dei dati non elaborati dei messaggi attraverso la pipeline specificata.

aws iotanalytics start-pipeline-reprocessing \
    --pipeline-name mypipeline

Output:

{
    "reprocessingId": "6ad2764f-fb13-4de3-b101-4e74af03b043"
}

Per ulteriori informazioni, StartPipelineReprocessingconsulta AWS IoT Analytics API Reference.

Per aggiungere o modificare i tag di una risorsa

L'tag-resourceesempio seguente aggiunge o modifica i tag allegati alla risorsa specificata.

aws iotanalytics tag-resource \
    --resource-arn "arn:aws:iotanalytics:us-west-2:123456789012:channel/mychannel" \
    --tags "[{\"key\": \"Environment\", \"value\": \"Production\"}]"

Questo comando non produce alcun output.

Per ulteriori informazioni, TagResourceconsulta AWS IoT Analytics API Reference.

Per rimuovere i tag da una risorsa

L'untag-resourceesempio seguente rimuove i tag con i nomi di chiave specificati dalla risorsa specificata.

aws iotanalytics untag-resource \
    --resource-arn "arn:aws:iotanalytics:us-west-2:123456789012:channel/mychannel" \
    --tag-keys "[\"Environment\"]"

Questo comando non produce alcun output.

Per ulteriori informazioni, consulta UntagResource < https://docs.aws.amazon.com/iotanalytics/ latest/APIReference/API _ UntagResource .html > in AWS IoT Analytics API Reference.

Per modificare un canale

L'update-channelesempio seguente modifica le impostazioni per il canale specificato.

aws iotanalytics update-channel \
    --cli-input-json file://update-channel.json

Contenuto di update-channel.json.

{
    "channelName": "mychannel",
    "retentionPeriod": {
        "numberOfDays": 92
    }
}

Questo comando non produce alcun output.

Per ulteriori informazioni, UpdateChannelconsulta AWS IoT Analytics API Reference.

Per aggiornare un set di dati

L'update-datasetesempio seguente modifica le impostazioni del set di dati specificato.

aws iotanalytics update-dataset \
    --cli-input-json file://update-dataset.json

Contenuto di update-dataset.json.

{
    "datasetName": "mydataset",
    "actions": [
        {
            "actionName": "myDatasetUpdateAction",
            "queryAction": {
                "sqlQuery": "SELECT * FROM mydatastore"
            }
        }
    ],
    "retentionPeriod": {
        "numberOfDays": 92
    }
}

Questo comando non produce alcun output.

Per ulteriori informazioni, consulta UpdateDataset < https://docs.aws.amazon.com/iotanalytics/ latest/APIReference/API _ UpdateDataset .html > in AWS IoT Analytics API Reference.

Per aggiornare un archivio dati

L'update-datastoreesempio seguente modifica le impostazioni del data store specificato.

aws iotanalytics update-datastore \
    --cli-input-json file://update-datastore.json

Contenuto di update-datastore.json:

{
    "datastoreName": "mydatastore",
    "retentionPeriod": {
        "numberOfDays": 93
    }
}

Questo comando non produce alcun output.

Per ulteriori informazioni, UpdateDatastoreconsulta AWS IoT Analytics API Reference.

Per aggiornare una pipeline

L'update-pipelineesempio seguente modifica le impostazioni della tubazione specificata. È necessario specificare sia un canale che un'attività di archivio dati e, facoltativamente, fino a 23 attività aggiuntive, nell'array. pipelineActivities

aws iotanalytics update-pipeline \
    --cli-input-json file://update-pipeline.json

Contenuto di update-pipeline.json:

{
    "pipelineName": "mypipeline",
    "pipelineActivities": [
        {
            "channel": {
                "name": "myChannelActivity",
                "channelName": "mychannel",
                "next": "myMathActivity"
            }
        },
        {
            "datastore": {
                "name": "myDatastoreActivity",
                "datastoreName": "mydatastore"
            }
        },
        {
            "math": {
                "name": "myMathActivity",
                "math": "(((temp - 32) * 5.0) / 9.0) + 273.15",
                "attribute": "tempK",
                "next": "myDatastoreActivity"
            }
        }
    ]
}

Questo comando non produce alcun output.

Per ulteriori informazioni, UpdatePipelineconsulta AWS IoT Analytics API Reference.