@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public interface AWSIoTAnalytics
Note: Do not directly implement this interface, new methods are added to it regularly. Extend from
AbstractAWSIoTAnalytics
instead.
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. 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.
IoT Analytics automates the steps required to analyze data from IoT devices. 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. 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.
Modifier and Type | Field and Description |
---|---|
static String |
ENDPOINT_PREFIX
The region metadata service name for computing region endpoints.
|
Modifier and Type | Method and Description |
---|---|
BatchPutMessageResult |
batchPutMessage(BatchPutMessageRequest batchPutMessageRequest)
Sends messages to a channel.
|
CancelPipelineReprocessingResult |
cancelPipelineReprocessing(CancelPipelineReprocessingRequest cancelPipelineReprocessingRequest)
Cancels the reprocessing of data through the pipeline.
|
CreateChannelResult |
createChannel(CreateChannelRequest createChannelRequest)
Used to create a channel.
|
CreateDatasetResult |
createDataset(CreateDatasetRequest createDatasetRequest)
Used to create a dataset.
|
CreateDatasetContentResult |
createDatasetContent(CreateDatasetContentRequest createDatasetContentRequest)
Creates the content of a dataset by applying a
queryAction (a SQL query) or a
containerAction (executing a containerized application). |
CreateDatastoreResult |
createDatastore(CreateDatastoreRequest createDatastoreRequest)
Creates a data store, which is a repository for messages.
|
CreatePipelineResult |
createPipeline(CreatePipelineRequest createPipelineRequest)
Creates a pipeline.
|
DeleteChannelResult |
deleteChannel(DeleteChannelRequest deleteChannelRequest)
Deletes the specified channel.
|
DeleteDatasetResult |
deleteDataset(DeleteDatasetRequest deleteDatasetRequest)
Deletes the specified dataset.
|
DeleteDatasetContentResult |
deleteDatasetContent(DeleteDatasetContentRequest deleteDatasetContentRequest)
Deletes the content of the specified dataset.
|
DeleteDatastoreResult |
deleteDatastore(DeleteDatastoreRequest deleteDatastoreRequest)
Deletes the specified data store.
|
DeletePipelineResult |
deletePipeline(DeletePipelineRequest deletePipelineRequest)
Deletes the specified pipeline.
|
DescribeChannelResult |
describeChannel(DescribeChannelRequest describeChannelRequest)
Retrieves information about a channel.
|
DescribeDatasetResult |
describeDataset(DescribeDatasetRequest describeDatasetRequest)
Retrieves information about a dataset.
|
DescribeDatastoreResult |
describeDatastore(DescribeDatastoreRequest describeDatastoreRequest)
Retrieves information about a data store.
|
DescribeLoggingOptionsResult |
describeLoggingOptions(DescribeLoggingOptionsRequest describeLoggingOptionsRequest)
Retrieves the current settings of the IoT Analytics logging options.
|
DescribePipelineResult |
describePipeline(DescribePipelineRequest describePipelineRequest)
Retrieves information about a pipeline.
|
ResponseMetadata |
getCachedResponseMetadata(AmazonWebServiceRequest request)
Returns additional metadata for a previously executed successful request, typically used for debugging issues
where a service isn't acting as expected.
|
GetDatasetContentResult |
getDatasetContent(GetDatasetContentRequest getDatasetContentRequest)
Retrieves the contents of a dataset as presigned URIs.
|
ListChannelsResult |
listChannels(ListChannelsRequest listChannelsRequest)
Retrieves a list of channels.
|
ListDatasetContentsResult |
listDatasetContents(ListDatasetContentsRequest listDatasetContentsRequest)
Lists information about dataset contents that have been created.
|
ListDatasetsResult |
listDatasets(ListDatasetsRequest listDatasetsRequest)
Retrieves information about datasets.
|
ListDatastoresResult |
listDatastores(ListDatastoresRequest listDatastoresRequest)
Retrieves a list of data stores.
|
ListPipelinesResult |
listPipelines(ListPipelinesRequest listPipelinesRequest)
Retrieves a list of pipelines.
|
ListTagsForResourceResult |
listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Lists the tags (metadata) that you have assigned to the resource.
|
PutLoggingOptionsResult |
putLoggingOptions(PutLoggingOptionsRequest putLoggingOptionsRequest)
Sets or updates the IoT Analytics logging options.
|
RunPipelineActivityResult |
runPipelineActivity(RunPipelineActivityRequest runPipelineActivityRequest)
Simulates the results of running a pipeline activity on a message payload.
|
SampleChannelDataResult |
sampleChannelData(SampleChannelDataRequest sampleChannelDataRequest)
Retrieves a sample of messages from the specified channel ingested during the specified timeframe.
|
void |
shutdown()
Shuts down this client object, releasing any resources that might be held open.
|
StartPipelineReprocessingResult |
startPipelineReprocessing(StartPipelineReprocessingRequest startPipelineReprocessingRequest)
Starts the reprocessing of raw message data through the pipeline.
|
TagResourceResult |
tagResource(TagResourceRequest tagResourceRequest)
Adds to or modifies the tags of the given resource.
|
UntagResourceResult |
untagResource(UntagResourceRequest untagResourceRequest)
Removes the given tags (metadata) from the resource.
|
UpdateChannelResult |
updateChannel(UpdateChannelRequest updateChannelRequest)
Used to update the settings of a channel.
|
UpdateDatasetResult |
updateDataset(UpdateDatasetRequest updateDatasetRequest)
Updates the settings of a dataset.
|
UpdateDatastoreResult |
updateDatastore(UpdateDatastoreRequest updateDatastoreRequest)
Used to update the settings of a data store.
|
UpdatePipelineResult |
updatePipeline(UpdatePipelineRequest updatePipelineRequest)
Updates the settings of a pipeline.
|
static final String ENDPOINT_PREFIX
BatchPutMessageResult batchPutMessage(BatchPutMessageRequest batchPutMessageRequest)
Sends messages to a channel.
batchPutMessageRequest
- ResourceNotFoundException
- A resource with the specified name could not be found.InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.CancelPipelineReprocessingResult cancelPipelineReprocessing(CancelPipelineReprocessingRequest cancelPipelineReprocessingRequest)
Cancels the reprocessing of data through the pipeline.
cancelPipelineReprocessingRequest
- ResourceNotFoundException
- A resource with the specified name could not be found.InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.CreateChannelResult createChannel(CreateChannelRequest createChannelRequest)
Used to create a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
createChannelRequest
- InvalidRequestException
- The request was not valid.ResourceAlreadyExistsException
- A resource with the same name already exists.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.CreateDatasetResult createDataset(CreateDatasetRequest createDatasetRequest)
Used to create a dataset. A dataset stores data retrieved from a data store by applying a
queryAction
(a SQL query) or a containerAction
(executing a containerized application).
This operation creates the skeleton of a dataset. The dataset can be populated manually by calling
CreateDatasetContent
or automatically according to a trigger you specify.
createDatasetRequest
- InvalidRequestException
- The request was not valid.ResourceAlreadyExistsException
- A resource with the same name already exists.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.CreateDatasetContentResult createDatasetContent(CreateDatasetContentRequest createDatasetContentRequest)
Creates the content of a dataset by applying a queryAction
(a SQL query) or a
containerAction
(executing a containerized application).
createDatasetContentRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.CreateDatastoreResult createDatastore(CreateDatastoreRequest createDatastoreRequest)
Creates a data store, which is a repository for messages.
createDatastoreRequest
- InvalidRequestException
- The request was not valid.ResourceAlreadyExistsException
- A resource with the same name already exists.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.CreatePipelineResult createPipeline(CreatePipelineRequest createPipelineRequest)
Creates a pipeline. A pipeline consumes messages from a channel and allows you to process the messages before
storing them in a data store. You must specify both a channel
and a datastore
activity
and, optionally, as many as 23 additional activities in the pipelineActivities
array.
createPipelineRequest
- InvalidRequestException
- The request was not valid.ResourceAlreadyExistsException
- A resource with the same name already exists.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.DeleteChannelResult deleteChannel(DeleteChannelRequest deleteChannelRequest)
Deletes the specified channel.
deleteChannelRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DeleteDatasetResult deleteDataset(DeleteDatasetRequest deleteDatasetRequest)
Deletes the specified dataset.
You do not have to delete the content of the dataset before you perform this operation.
deleteDatasetRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DeleteDatasetContentResult deleteDatasetContent(DeleteDatasetContentRequest deleteDatasetContentRequest)
Deletes the content of the specified dataset.
deleteDatasetContentRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DeleteDatastoreResult deleteDatastore(DeleteDatastoreRequest deleteDatastoreRequest)
Deletes the specified data store.
deleteDatastoreRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DeletePipelineResult deletePipeline(DeletePipelineRequest deletePipelineRequest)
Deletes the specified pipeline.
deletePipelineRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DescribeChannelResult describeChannel(DescribeChannelRequest describeChannelRequest)
Retrieves information about a channel.
describeChannelRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DescribeDatasetResult describeDataset(DescribeDatasetRequest describeDatasetRequest)
Retrieves information about a dataset.
describeDatasetRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DescribeDatastoreResult describeDatastore(DescribeDatastoreRequest describeDatastoreRequest)
Retrieves information about a data store.
describeDatastoreRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DescribeLoggingOptionsResult describeLoggingOptions(DescribeLoggingOptionsRequest describeLoggingOptionsRequest)
Retrieves the current settings of the IoT Analytics logging options.
describeLoggingOptionsRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.DescribePipelineResult describePipeline(DescribePipelineRequest describePipelineRequest)
Retrieves information about a pipeline.
describePipelineRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.GetDatasetContentResult getDatasetContent(GetDatasetContentRequest getDatasetContentRequest)
Retrieves the contents of a dataset as presigned URIs.
getDatasetContentRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ListChannelsResult listChannels(ListChannelsRequest listChannelsRequest)
Retrieves a list of channels.
listChannelsRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ListDatasetContentsResult listDatasetContents(ListDatasetContentsRequest listDatasetContentsRequest)
Lists information about dataset contents that have been created.
listDatasetContentsRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ResourceNotFoundException
- A resource with the specified name could not be found.ListDatasetsResult listDatasets(ListDatasetsRequest listDatasetsRequest)
Retrieves information about datasets.
listDatasetsRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ListDatastoresResult listDatastores(ListDatastoresRequest listDatastoresRequest)
Retrieves a list of data stores.
listDatastoresRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ListPipelinesResult listPipelines(ListPipelinesRequest listPipelinesRequest)
Retrieves a list of pipelines.
listPipelinesRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.ListTagsForResourceResult listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Lists the tags (metadata) that you have assigned to the resource.
listTagsForResourceRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.ResourceNotFoundException
- A resource with the specified name could not be found.PutLoggingOptionsResult putLoggingOptions(PutLoggingOptionsRequest putLoggingOptionsRequest)
Sets or updates the IoT Analytics logging options.
If you update the value of any loggingOptions
field, it takes up to one minute for the change to
take effect. Also, if you change the policy attached to the role you specified in the roleArn
field
(for example, to correct an invalid policy), it takes up to five minutes for that change to take effect.
putLoggingOptionsRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.RunPipelineActivityResult runPipelineActivity(RunPipelineActivityRequest runPipelineActivityRequest)
Simulates the results of running a pipeline activity on a message payload.
runPipelineActivityRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.SampleChannelDataResult sampleChannelData(SampleChannelDataRequest sampleChannelDataRequest)
Retrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
sampleChannelDataRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.StartPipelineReprocessingResult startPipelineReprocessing(StartPipelineReprocessingRequest startPipelineReprocessingRequest)
Starts the reprocessing of raw message data through the pipeline.
startPipelineReprocessingRequest
- ResourceNotFoundException
- A resource with the specified name could not be found.ResourceAlreadyExistsException
- A resource with the same name already exists.InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.TagResourceResult tagResource(TagResourceRequest tagResourceRequest)
Adds to or modifies the tags of the given resource. Tags are metadata that can be used to manage a resource.
tagResourceRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.ResourceNotFoundException
- A resource with the specified name could not be found.UntagResourceResult untagResource(UntagResourceRequest untagResourceRequest)
Removes the given tags (metadata) from the resource.
untagResourceRequest
- InvalidRequestException
- The request was not valid.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.ResourceNotFoundException
- A resource with the specified name could not be found.UpdateChannelResult updateChannel(UpdateChannelRequest updateChannelRequest)
Used to update the settings of a channel.
updateChannelRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.UpdateDatasetResult updateDataset(UpdateDatasetRequest updateDatasetRequest)
Updates the settings of a dataset.
updateDatasetRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.UpdateDatastoreResult updateDatastore(UpdateDatastoreRequest updateDatastoreRequest)
Used to update the settings of a data store.
updateDatastoreRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.UpdatePipelineResult updatePipeline(UpdatePipelineRequest updatePipelineRequest)
Updates the settings of a pipeline. You must specify both a channel
and a datastore
activity and, optionally, as many as 23 additional activities in the pipelineActivities
array.
updatePipelineRequest
- InvalidRequestException
- The request was not valid.ResourceNotFoundException
- A resource with the specified name could not be found.InternalFailureException
- There was an internal failure.ServiceUnavailableException
- The service is temporarily unavailable.ThrottlingException
- The request was denied due to request throttling.LimitExceededException
- The command caused an internal limit to be exceeded.void shutdown()
ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request)
Response metadata is only cached for a limited period of time, so if you need to access this extra diagnostic information for an executed request, you should use this method to retrieve it as soon as possible after executing a request.
request
- The originally executed request.