[][src]Crate rusoto_iotanalytics

AWS IoT Analytics allows you to collect large amounts of device data, process messages, and store them. You can then query the data and run sophisticated analytics on it. AWS IoT Analytics enables advanced data exploration through integration with Jupyter Notebooks and data visualization through integration with Amazon QuickSight.

Traditional analytics and business intelligence tools are designed to process structured data. IoT data often comes from devices that record noisy processes (such as temperature, motion, or sound). As a result the data from these devices can have significant gaps, corrupted messages, and false readings that must be cleaned up before analysis can occur. Also, IoT data is often only meaningful in the context of other data from external sources.

AWS IoT Analytics automates the steps required to analyze data from IoT devices. AWS IoT Analytics filters, transforms, and enriches IoT data before storing it in a time-series data store for analysis. You can set up the service to collect only the data you need from your devices, apply mathematical transforms to process the data, and enrich the data with device-specific metadata such as device type and location before storing it. Then, you can analyze your data by running queries using the built-in SQL query engine, or perform more complex analytics and machine learning inference. AWS IoT Analytics includes pre-built models for common IoT use cases so you can answer questions like which devices are about to fail or which customers are at risk of abandoning their wearable devices.

If you're using the service, you're probably looking for IotAnalyticsClient and IotAnalytics.

Structs

AddAttributesActivity

An activity that adds other attributes based on existing attributes in the message.

BatchPutMessageErrorEntry

Contains informations about errors.

BatchPutMessageRequest
BatchPutMessageResponse
CancelPipelineReprocessingRequest
CancelPipelineReprocessingResponse
Channel

A collection of data from an MQTT topic. Channels archive the raw, unprocessed messages before publishing the data to a pipeline.

ChannelActivity

The activity that determines the source of the messages to be processed.

ChannelMessages

Specifies one or more sets of channel messages.

ChannelStatistics

Statistics information about the channel.

ChannelStorage

Where channel data is stored. You may choose one of serviceManagedS3 or customerManagedS3 storage. If not specified, the default is serviceManagedS3. This cannot be changed after creation of the channel.

ChannelStorageSummary

Where channel data is stored.

ChannelSummary

A summary of information about a channel.

Column

Contains information about a column that stores your data.

ContainerDatasetAction

Information required to run the containerAction to produce dataset contents.

CreateChannelRequest
CreateChannelResponse
CreateDatasetContentRequest
CreateDatasetContentResponse
CreateDatasetRequest
CreateDatasetResponse
CreateDatastoreRequest
CreateDatastoreResponse
CreatePipelineRequest
CreatePipelineResponse
CustomerManagedChannelS3Storage

Use this to store channel data in an S3 bucket that you manage. If customer managed storage is selected, the retentionPeriod parameter is ignored. You cannot change the choice of service-managed or customer-managed S3 storage after the channel is created.

CustomerManagedChannelS3StorageSummary

Used to store channel data in an S3 bucket that you manage.

CustomerManagedDatastoreS3Storage

Use this to store data store data in an S3 bucket that you manage. When customer-managed storage is selected, the retentionPeriod parameter is ignored. You cannot change the choice of service-managed or customer-managed S3 storage after the data store is created.

CustomerManagedDatastoreS3StorageSummary

Used to store data store data in an S3 bucket that you manage.

Dataset

Information about a data set.

DatasetAction

A DatasetAction object that specifies how data set contents are automatically created.

DatasetActionSummary

Information about the action that automatically creates the dataset's contents.

DatasetContentDeliveryDestination

The destination to which dataset contents are delivered.

DatasetContentDeliveryRule

When dataset contents are created, they are delivered to destination specified here.

DatasetContentStatus

The state of the data set contents and the reason they are in this state.

DatasetContentSummary

Summary information about dataset contents.

DatasetContentVersionValue

The dataset whose latest contents are used as input to the notebook or application.

DatasetEntry

The reference to a data set entry.

DatasetSummary

A summary of information about a data set.

DatasetTrigger

The DatasetTrigger that specifies when the data set is automatically updated.

Datastore

Information about a data store.

DatastoreActivity

The datastore activity that specifies where to store the processed data.

DatastoreStatistics

Statistical information about the data store.

DatastoreStorage

Where data store data is stored. You can choose one of serviceManagedS3 or customerManagedS3 storage. If not specified, the default is serviceManagedS3. You cannot change this storage option after the data store is created.

DatastoreStorageSummary

Where data store data is stored.

DatastoreSummary

A summary of information about a data store.

DeleteChannelRequest
DeleteDatasetContentRequest
DeleteDatasetRequest
DeleteDatastoreRequest
DeletePipelineRequest
DeltaTime

Used to limit data to that which has arrived since the last execution of the action.

DeltaTimeSessionWindowConfiguration

A structure that contains the configuration information of a delta time session window.

DeltaTime specifies a time interval. You can use DeltaTime to create dataset contents with data that has arrived in the data store since the last execution. For an example of DeltaTime, see Creating a SQL dataset with a delta window (CLI) in the AWS IoT Analytics User Guide.

DescribeChannelRequest
DescribeChannelResponse
DescribeDatasetRequest
DescribeDatasetResponse
DescribeDatastoreRequest
DescribeDatastoreResponse
DescribeLoggingOptionsRequest
DescribeLoggingOptionsResponse
DescribePipelineRequest
DescribePipelineResponse
DeviceRegistryEnrichActivity

An activity that adds data from the AWS IoT device registry to your message.

DeviceShadowEnrichActivity

An activity that adds information from the AWS IoT Device Shadow service to a message.

EstimatedResourceSize

The estimated size of the resource.

FileFormatConfiguration

Contains the configuration information of file formats. AWS IoT Analytics data stores support JSON and Parquet.

The default file format is JSON. You can specify only one format.

You can't change the file format after you create the data store.

FilterActivity

An activity that filters a message based on its attributes.

GetDatasetContentRequest
GetDatasetContentResponse
GlueConfiguration

Configuration information for coordination with AWS Glue, a fully managed extract, transform and load (ETL) service.

IotAnalyticsClient

A client for the AWS IoT Analytics API.

IotEventsDestinationConfiguration

Configuration information for delivery of dataset contents to AWS IoT Events.

JsonConfiguration

Contains the configuration information of the JSON format.

LambdaActivity

An activity that runs a Lambda function to modify the message.

LateDataRule

A structure that contains the name and configuration information of a late data rule.

LateDataRuleConfiguration

The information needed to configure a delta time session window.

ListChannelsRequest
ListChannelsResponse
ListDatasetContentsRequest
ListDatasetContentsResponse
ListDatasetsRequest
ListDatasetsResponse
ListDatastoresRequest
ListDatastoresResponse
ListPipelinesRequest
ListPipelinesResponse
ListTagsForResourceRequest
ListTagsForResourceResponse
LoggingOptions

Information about logging options.

MathActivity

An activity that computes an arithmetic expression using the message's attributes.

Message

Information about a message.

OutputFileUriValue

The value of the variable as a structure that specifies an output file URI.

ParquetConfiguration

Contains the configuration information of the Parquet format.

Pipeline

Contains information about a pipeline.

PipelineActivity

An activity that performs a transformation on a message.

PipelineSummary

A summary of information about a pipeline.

PutLoggingOptionsRequest
QueryFilter

Information that is used to filter message data, to segregate it according to the timeframe in which it arrives.

RemoveAttributesActivity

An activity that removes attributes from a message.

ReprocessingSummary

Information about pipeline reprocessing.

ResourceConfiguration

The configuration of the resource used to execute the containerAction.

RetentionPeriod

How long, in days, message data is kept.

RunPipelineActivityRequest
RunPipelineActivityResponse
S3DestinationConfiguration

Configuration information for delivery of dataset contents to Amazon Simple Storage Service (Amazon S3).

SampleChannelDataRequest
SampleChannelDataResponse
Schedule

The schedule for when to trigger an update.

SchemaDefinition

Information needed to define a schema.

SelectAttributesActivity

Creates a new message using only the specified attributes from the original message.

ServiceManagedChannelS3Storage

Use this to store channel data in an S3 bucket managed by AWS IoT Analytics. You cannot change the choice of service-managed or customer-managed S3 storage after the channel is created.

ServiceManagedChannelS3StorageSummary

Used to store channel data in an S3 bucket managed by AWS IoT Analytics.

ServiceManagedDatastoreS3Storage

Use this to store data store data in an S3 bucket managed by AWS IoT Analytics. You cannot change the choice of service-managed or customer-managed S3 storage after the data store is created.

ServiceManagedDatastoreS3StorageSummary

Used to store data store data in an S3 bucket managed by AWS IoT Analytics.

SqlQueryDatasetAction

The SQL query to modify the message.

StartPipelineReprocessingRequest
StartPipelineReprocessingResponse
Tag

A set of key-value pairs that are used to manage the resource.

TagResourceRequest
TagResourceResponse
TriggeringDataset

Information about the dataset whose content generation triggers the new dataset content generation.

UntagResourceRequest
UntagResourceResponse
UpdateChannelRequest
UpdateDatasetRequest
UpdateDatastoreRequest
UpdatePipelineRequest
Variable

An instance of a variable to be passed to the containerAction execution. Each variable must have a name and a value given by one of stringValue, datasetContentVersionValue, or outputFileUriValue.

VersioningConfiguration

Information about the versioning of dataset contents.

Enums

BatchPutMessageError

Errors returned by BatchPutMessage

CancelPipelineReprocessingError

Errors returned by CancelPipelineReprocessing

CreateChannelError

Errors returned by CreateChannel

CreateDatasetContentError

Errors returned by CreateDatasetContent

CreateDatasetError

Errors returned by CreateDataset

CreateDatastoreError

Errors returned by CreateDatastore

CreatePipelineError

Errors returned by CreatePipeline

DeleteChannelError

Errors returned by DeleteChannel

DeleteDatasetContentError

Errors returned by DeleteDatasetContent

DeleteDatasetError

Errors returned by DeleteDataset

DeleteDatastoreError

Errors returned by DeleteDatastore

DeletePipelineError

Errors returned by DeletePipeline

DescribeChannelError

Errors returned by DescribeChannel

DescribeDatasetError

Errors returned by DescribeDataset

DescribeDatastoreError

Errors returned by DescribeDatastore

DescribeLoggingOptionsError

Errors returned by DescribeLoggingOptions

DescribePipelineError

Errors returned by DescribePipeline

GetDatasetContentError

Errors returned by GetDatasetContent

ListChannelsError

Errors returned by ListChannels

ListDatasetContentsError

Errors returned by ListDatasetContents

ListDatasetsError

Errors returned by ListDatasets

ListDatastoresError

Errors returned by ListDatastores

ListPipelinesError

Errors returned by ListPipelines

ListTagsForResourceError

Errors returned by ListTagsForResource

PutLoggingOptionsError

Errors returned by PutLoggingOptions

RunPipelineActivityError

Errors returned by RunPipelineActivity

SampleChannelDataError

Errors returned by SampleChannelData

StartPipelineReprocessingError

Errors returned by StartPipelineReprocessing

TagResourceError

Errors returned by TagResource

UntagResourceError

Errors returned by UntagResource

UpdateChannelError

Errors returned by UpdateChannel

UpdateDatasetError

Errors returned by UpdateDataset

UpdateDatastoreError

Errors returned by UpdateDatastore

UpdatePipelineError

Errors returned by UpdatePipeline

Traits

IotAnalytics

Trait representing the capabilities of the AWS IoT Analytics API. AWS IoT Analytics clients implement this trait.