/*
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
/*
* Do not modify this file. This file is generated from the iotanalytics-2017-11-27.normal.json service model.
*/
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using Amazon.Runtime;
using Amazon.IoTAnalytics.Model;
namespace Amazon.IoTAnalytics
{
///
/// Interface for accessing IoTAnalytics
///
/// 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.
///
///
public partial interface IAmazonIoTAnalytics : IAmazonService, IDisposable
{
///
/// Paginators for the service
///
IIoTAnalyticsPaginatorFactory Paginators { get; }
#region BatchPutMessage
///
/// Sends messages to a channel.
///
/// Container for the necessary parameters to execute the BatchPutMessage service method.
///
/// The response from the BatchPutMessage service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for BatchPutMessage Operation
BatchPutMessageResponse BatchPutMessage(BatchPutMessageRequest request);
///
/// Sends messages to a channel.
///
/// Container for the necessary parameters to execute the BatchPutMessage service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the BatchPutMessage service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for BatchPutMessage Operation
Task BatchPutMessageAsync(BatchPutMessageRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CancelPipelineReprocessing
///
/// Cancels the reprocessing of data through the pipeline.
///
/// Container for the necessary parameters to execute the CancelPipelineReprocessing service method.
///
/// The response from the CancelPipelineReprocessing service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CancelPipelineReprocessing Operation
CancelPipelineReprocessingResponse CancelPipelineReprocessing(CancelPipelineReprocessingRequest request);
///
/// Cancels the reprocessing of data through the pipeline.
///
/// Container for the necessary parameters to execute the CancelPipelineReprocessing service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CancelPipelineReprocessing service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CancelPipelineReprocessing Operation
Task CancelPipelineReprocessingAsync(CancelPipelineReprocessingRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateChannel
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateChannel service method.
///
/// The response from the CreateChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateChannel Operation
CreateChannelResponse CreateChannel(CreateChannelRequest request);
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateChannel service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateChannel Operation
Task CreateChannelAsync(CreateChannelRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateDataset
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateDataset service method.
///
/// The response from the CreateDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDataset Operation
CreateDatasetResponse CreateDataset(CreateDatasetRequest request);
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateDataset service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDataset Operation
Task CreateDatasetAsync(CreateDatasetRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateDatasetContent
///
/// Creates the content of a dataset by applying a queryAction (a SQL query)
/// or a containerAction (executing a containerized application).
///
/// Container for the necessary parameters to execute the CreateDatasetContent service method.
///
/// The response from the CreateDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDatasetContent Operation
CreateDatasetContentResponse CreateDatasetContent(CreateDatasetContentRequest request);
///
/// Creates the content of a dataset by applying a queryAction (a SQL query)
/// or a containerAction (executing a containerized application).
///
/// Container for the necessary parameters to execute the CreateDatasetContent service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDatasetContent Operation
Task CreateDatasetContentAsync(CreateDatasetContentRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateDatastore
///
/// Creates a data store, which is a repository for messages.
///
/// Container for the necessary parameters to execute the CreateDatastore service method.
///
/// The response from the CreateDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDatastore Operation
CreateDatastoreResponse CreateDatastore(CreateDatastoreRequest request);
///
/// Creates a data store, which is a repository for messages.
///
/// Container for the necessary parameters to execute the CreateDatastore service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreateDatastore Operation
Task CreateDatastoreAsync(CreateDatastoreRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreatePipeline
///
/// 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.
///
/// Container for the necessary parameters to execute the CreatePipeline service method.
///
/// The response from the CreatePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreatePipeline Operation
CreatePipelineResponse CreatePipeline(CreatePipelineRequest request);
///
/// 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.
///
/// Container for the necessary parameters to execute the CreatePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreatePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the same name already exists.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for CreatePipeline Operation
Task CreatePipelineAsync(CreatePipelineRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteChannel
///
/// Deletes the specified channel.
///
/// Container for the necessary parameters to execute the DeleteChannel service method.
///
/// The response from the DeleteChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteChannel Operation
DeleteChannelResponse DeleteChannel(DeleteChannelRequest request);
///
/// Deletes the specified channel.
///
/// Container for the necessary parameters to execute the DeleteChannel service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteChannel Operation
Task DeleteChannelAsync(DeleteChannelRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteDataset
///
/// Deletes the specified dataset.
///
///
///
/// You do not have to delete the content of the dataset before you perform this operation.
///
///
/// Container for the necessary parameters to execute the DeleteDataset service method.
///
/// The response from the DeleteDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDataset Operation
DeleteDatasetResponse DeleteDataset(DeleteDatasetRequest request);
///
/// Deletes the specified dataset.
///
///
///
/// You do not have to delete the content of the dataset before you perform this operation.
///
///
/// Container for the necessary parameters to execute the DeleteDataset service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDataset Operation
Task DeleteDatasetAsync(DeleteDatasetRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteDatasetContent
///
/// Deletes the content of the specified dataset.
///
/// Container for the necessary parameters to execute the DeleteDatasetContent service method.
///
/// The response from the DeleteDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDatasetContent Operation
DeleteDatasetContentResponse DeleteDatasetContent(DeleteDatasetContentRequest request);
///
/// Deletes the content of the specified dataset.
///
/// Container for the necessary parameters to execute the DeleteDatasetContent service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDatasetContent Operation
Task DeleteDatasetContentAsync(DeleteDatasetContentRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteDatastore
///
/// Deletes the specified data store.
///
/// Container for the necessary parameters to execute the DeleteDatastore service method.
///
/// The response from the DeleteDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDatastore Operation
DeleteDatastoreResponse DeleteDatastore(DeleteDatastoreRequest request);
///
/// Deletes the specified data store.
///
/// Container for the necessary parameters to execute the DeleteDatastore service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeleteDatastore Operation
Task DeleteDatastoreAsync(DeleteDatastoreRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeletePipeline
///
/// Deletes the specified pipeline.
///
/// Container for the necessary parameters to execute the DeletePipeline service method.
///
/// The response from the DeletePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeletePipeline Operation
DeletePipelineResponse DeletePipeline(DeletePipelineRequest request);
///
/// Deletes the specified pipeline.
///
/// Container for the necessary parameters to execute the DeletePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeletePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DeletePipeline Operation
Task DeletePipelineAsync(DeletePipelineRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeChannel
///
/// Retrieves information about a channel.
///
/// Container for the necessary parameters to execute the DescribeChannel service method.
///
/// The response from the DescribeChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeChannel Operation
DescribeChannelResponse DescribeChannel(DescribeChannelRequest request);
///
/// Retrieves information about a channel.
///
/// Container for the necessary parameters to execute the DescribeChannel service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeChannel Operation
Task DescribeChannelAsync(DescribeChannelRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeDataset
///
/// Retrieves information about a dataset.
///
/// Container for the necessary parameters to execute the DescribeDataset service method.
///
/// The response from the DescribeDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeDataset Operation
DescribeDatasetResponse DescribeDataset(DescribeDatasetRequest request);
///
/// Retrieves information about a dataset.
///
/// Container for the necessary parameters to execute the DescribeDataset service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeDataset Operation
Task DescribeDatasetAsync(DescribeDatasetRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeDatastore
///
/// Retrieves information about a data store.
///
/// Container for the necessary parameters to execute the DescribeDatastore service method.
///
/// The response from the DescribeDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeDatastore Operation
DescribeDatastoreResponse DescribeDatastore(DescribeDatastoreRequest request);
///
/// Retrieves information about a data store.
///
/// Container for the necessary parameters to execute the DescribeDatastore service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeDatastore Operation
Task DescribeDatastoreAsync(DescribeDatastoreRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeLoggingOptions
///
/// Retrieves the current settings of the IoT Analytics logging options.
///
/// Container for the necessary parameters to execute the DescribeLoggingOptions service method.
///
/// The response from the DescribeLoggingOptions service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeLoggingOptions Operation
DescribeLoggingOptionsResponse DescribeLoggingOptions(DescribeLoggingOptionsRequest request);
///
/// Retrieves the current settings of the IoT Analytics logging options.
///
/// Container for the necessary parameters to execute the DescribeLoggingOptions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeLoggingOptions service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribeLoggingOptions Operation
Task DescribeLoggingOptionsAsync(DescribeLoggingOptionsRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribePipeline
///
/// Retrieves information about a pipeline.
///
/// Container for the necessary parameters to execute the DescribePipeline service method.
///
/// The response from the DescribePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribePipeline Operation
DescribePipelineResponse DescribePipeline(DescribePipelineRequest request);
///
/// Retrieves information about a pipeline.
///
/// Container for the necessary parameters to execute the DescribePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for DescribePipeline Operation
Task DescribePipelineAsync(DescribePipelineRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region GetDatasetContent
///
/// Retrieves the contents of a dataset as presigned URIs.
///
/// Container for the necessary parameters to execute the GetDatasetContent service method.
///
/// The response from the GetDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for GetDatasetContent Operation
GetDatasetContentResponse GetDatasetContent(GetDatasetContentRequest request);
///
/// Retrieves the contents of a dataset as presigned URIs.
///
/// Container for the necessary parameters to execute the GetDatasetContent service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetDatasetContent service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for GetDatasetContent Operation
Task GetDatasetContentAsync(GetDatasetContentRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListChannels
///
/// Retrieves a list of channels.
///
/// Container for the necessary parameters to execute the ListChannels service method.
///
/// The response from the ListChannels service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListChannels Operation
ListChannelsResponse ListChannels(ListChannelsRequest request);
///
/// Retrieves a list of channels.
///
/// Container for the necessary parameters to execute the ListChannels service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListChannels service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListChannels Operation
Task ListChannelsAsync(ListChannelsRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListDatasetContents
///
/// Lists information about dataset contents that have been created.
///
/// Container for the necessary parameters to execute the ListDatasetContents service method.
///
/// The response from the ListDatasetContents service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatasetContents Operation
ListDatasetContentsResponse ListDatasetContents(ListDatasetContentsRequest request);
///
/// Lists information about dataset contents that have been created.
///
/// Container for the necessary parameters to execute the ListDatasetContents service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListDatasetContents service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatasetContents Operation
Task ListDatasetContentsAsync(ListDatasetContentsRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListDatasets
///
/// Retrieves information about datasets.
///
/// Container for the necessary parameters to execute the ListDatasets service method.
///
/// The response from the ListDatasets service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatasets Operation
ListDatasetsResponse ListDatasets(ListDatasetsRequest request);
///
/// Retrieves information about datasets.
///
/// Container for the necessary parameters to execute the ListDatasets service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListDatasets service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatasets Operation
Task ListDatasetsAsync(ListDatasetsRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListDatastores
///
/// Retrieves a list of data stores.
///
/// Container for the necessary parameters to execute the ListDatastores service method.
///
/// The response from the ListDatastores service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatastores Operation
ListDatastoresResponse ListDatastores(ListDatastoresRequest request);
///
/// Retrieves a list of data stores.
///
/// Container for the necessary parameters to execute the ListDatastores service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListDatastores service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListDatastores Operation
Task ListDatastoresAsync(ListDatastoresRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListPipelines
///
/// Retrieves a list of pipelines.
///
/// Container for the necessary parameters to execute the ListPipelines service method.
///
/// The response from the ListPipelines service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListPipelines Operation
ListPipelinesResponse ListPipelines(ListPipelinesRequest request);
///
/// Retrieves a list of pipelines.
///
/// Container for the necessary parameters to execute the ListPipelines service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListPipelines service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListPipelines Operation
Task ListPipelinesAsync(ListPipelinesRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListTagsForResource
///
/// Lists the tags (metadata) that you have assigned to the resource.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListTagsForResource Operation
ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request);
///
/// Lists the tags (metadata) that you have assigned to the resource.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListTagsForResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for ListTagsForResource Operation
Task ListTagsForResourceAsync(ListTagsForResourceRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region PutLoggingOptions
///
/// 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.
///
///
/// Container for the necessary parameters to execute the PutLoggingOptions service method.
///
/// The response from the PutLoggingOptions service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for PutLoggingOptions Operation
PutLoggingOptionsResponse PutLoggingOptions(PutLoggingOptionsRequest request);
///
/// 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.
///
///
/// Container for the necessary parameters to execute the PutLoggingOptions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutLoggingOptions service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for PutLoggingOptions Operation
Task PutLoggingOptionsAsync(PutLoggingOptionsRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region RunPipelineActivity
///
/// Simulates the results of running a pipeline activity on a message payload.
///
/// Container for the necessary parameters to execute the RunPipelineActivity service method.
///
/// The response from the RunPipelineActivity service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for RunPipelineActivity Operation
RunPipelineActivityResponse RunPipelineActivity(RunPipelineActivityRequest request);
///
/// Simulates the results of running a pipeline activity on a message payload.
///
/// Container for the necessary parameters to execute the RunPipelineActivity service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RunPipelineActivity service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for RunPipelineActivity Operation
Task RunPipelineActivityAsync(RunPipelineActivityRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region SampleChannelData
///
/// Retrieves a sample of messages from the specified channel ingested during the specified
/// timeframe. Up to 10 messages can be retrieved.
///
/// Container for the necessary parameters to execute the SampleChannelData service method.
///
/// The response from the SampleChannelData service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for SampleChannelData Operation
SampleChannelDataResponse SampleChannelData(SampleChannelDataRequest request);
///
/// Retrieves a sample of messages from the specified channel ingested during the specified
/// timeframe. Up to 10 messages can be retrieved.
///
/// Container for the necessary parameters to execute the SampleChannelData service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the SampleChannelData service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for SampleChannelData Operation
Task SampleChannelDataAsync(SampleChannelDataRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region StartPipelineReprocessing
///
/// Starts the reprocessing of raw message data through the pipeline.
///
/// Container for the necessary parameters to execute the StartPipelineReprocessing service method.
///
/// The response from the StartPipelineReprocessing service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the same name already exists.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for StartPipelineReprocessing Operation
StartPipelineReprocessingResponse StartPipelineReprocessing(StartPipelineReprocessingRequest request);
///
/// Starts the reprocessing of raw message data through the pipeline.
///
/// Container for the necessary parameters to execute the StartPipelineReprocessing service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartPipelineReprocessing service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the same name already exists.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for StartPipelineReprocessing Operation
Task StartPipelineReprocessingAsync(StartPipelineReprocessingRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region TagResource
///
/// Adds to or modifies the tags of the given resource. Tags are metadata that can be
/// used to manage a resource.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for TagResource Operation
TagResourceResponse TagResource(TagResourceRequest request);
///
/// Adds to or modifies the tags of the given resource. Tags are metadata that can be
/// used to manage a resource.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the TagResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for TagResource Operation
Task TagResourceAsync(TagResourceRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UntagResource
///
/// Removes the given tags (metadata) from the resource.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UntagResource Operation
UntagResourceResponse UntagResource(UntagResourceRequest request);
///
/// Removes the given tags (metadata) from the resource.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UntagResource service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UntagResource Operation
Task UntagResourceAsync(UntagResourceRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UpdateChannel
///
/// Used to update the settings of a channel.
///
/// Container for the necessary parameters to execute the UpdateChannel service method.
///
/// The response from the UpdateChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateChannel Operation
UpdateChannelResponse UpdateChannel(UpdateChannelRequest request);
///
/// Used to update the settings of a channel.
///
/// Container for the necessary parameters to execute the UpdateChannel service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateChannel service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateChannel Operation
Task UpdateChannelAsync(UpdateChannelRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UpdateDataset
///
/// Updates the settings of a dataset.
///
/// Container for the necessary parameters to execute the UpdateDataset service method.
///
/// The response from the UpdateDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateDataset Operation
UpdateDatasetResponse UpdateDataset(UpdateDatasetRequest request);
///
/// Updates the settings of a dataset.
///
/// Container for the necessary parameters to execute the UpdateDataset service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateDataset service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateDataset Operation
Task UpdateDatasetAsync(UpdateDatasetRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UpdateDatastore
///
/// Used to update the settings of a data store.
///
/// Container for the necessary parameters to execute the UpdateDatastore service method.
///
/// The response from the UpdateDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateDatastore Operation
UpdateDatastoreResponse UpdateDatastore(UpdateDatastoreRequest request);
///
/// Used to update the settings of a data store.
///
/// Container for the necessary parameters to execute the UpdateDatastore service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateDatastore service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdateDatastore Operation
Task UpdateDatastoreAsync(UpdateDatastoreRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UpdatePipeline
///
/// 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.
///
/// Container for the necessary parameters to execute the UpdatePipeline service method.
///
/// The response from the UpdatePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdatePipeline Operation
UpdatePipelineResponse UpdatePipeline(UpdatePipelineRequest request);
///
/// 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.
///
/// Container for the necessary parameters to execute the UpdatePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdatePipeline service method, as returned by IoTAnalytics.
///
/// There was an internal failure.
///
///
/// The request was not valid.
///
///
/// The command caused an internal limit to be exceeded.
///
///
/// A resource with the specified name could not be found.
///
///
/// The service is temporarily unavailable.
///
///
/// The request was denied due to request throttling.
///
/// REST API Reference for UpdatePipeline Operation
Task UpdatePipelineAsync(UpdatePipelineRequest request, CancellationToken cancellationToken = default(CancellationToken));
#endregion
}
}