/*
* 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.Runtime.ExceptionServices;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Net;
using Amazon.IoTAnalytics.Model;
using Amazon.IoTAnalytics.Model.Internal.MarshallTransformations;
using Amazon.IoTAnalytics.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.IoTAnalytics
{
///
/// Implementation 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 class AmazonIoTAnalyticsClient : AmazonServiceClient, IAmazonIoTAnalytics
{
private static IServiceMetadata serviceMetadata = new AmazonIoTAnalyticsMetadata();
private IIoTAnalyticsPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IIoTAnalyticsPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new IoTAnalyticsPaginatorFactory(this);
}
return this._paginators;
}
}
#region Constructors
///
/// Constructs AmazonIoTAnalyticsClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
public AmazonIoTAnalyticsClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonIoTAnalyticsConfig()) { }
///
/// Constructs AmazonIoTAnalyticsClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The region to connect.
public AmazonIoTAnalyticsClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonIoTAnalyticsConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonIoTAnalyticsClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The AmazonIoTAnalyticsClient Configuration Object
public AmazonIoTAnalyticsClient(AmazonIoTAnalyticsConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Credentials
///
/// AWS Credentials
public AmazonIoTAnalyticsClient(AWSCredentials credentials)
: this(credentials, new AmazonIoTAnalyticsConfig())
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonIoTAnalyticsClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonIoTAnalyticsConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Credentials and an
/// AmazonIoTAnalyticsClient Configuration object.
///
/// AWS Credentials
/// The AmazonIoTAnalyticsClient Configuration Object
public AmazonIoTAnalyticsClient(AWSCredentials credentials, AmazonIoTAnalyticsConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonIoTAnalyticsConfig())
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonIoTAnalyticsConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonIoTAnalyticsClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonIoTAnalyticsClient Configuration Object
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonIoTAnalyticsConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonIoTAnalyticsConfig())
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The region to connect.
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonIoTAnalyticsConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonIoTAnalyticsClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonIoTAnalyticsClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonIoTAnalyticsClient Configuration Object
public AmazonIoTAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonIoTAnalyticsConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig)
{
}
#endregion
#region Overrides
///
/// Creates the signer for the service.
///
protected override AbstractAWSSigner CreateSigner()
{
return new AWS4Signer();
}
///
/// Customize the pipeline
///
///
protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline)
{
pipeline.RemoveHandler();
pipeline.AddHandlerAfter(new AmazonIoTAnalyticsEndpointResolver());
}
///
/// Capture metadata for the service.
///
protected override IServiceMetadata ServiceMetadata
{
get
{
return serviceMetadata;
}
}
#endregion
#region Dispose
///
/// Disposes the service client.
///
protected override void Dispose(bool disposing)
{
base.Dispose(disposing);
}
#endregion
#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
public virtual BatchPutMessageResponse BatchPutMessage(BatchPutMessageRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchPutMessageRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchPutMessageResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task BatchPutMessageAsync(BatchPutMessageRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchPutMessageRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchPutMessageResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CancelPipelineReprocessingResponse CancelPipelineReprocessing(CancelPipelineReprocessingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelPipelineReprocessingRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelPipelineReprocessingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CancelPipelineReprocessingAsync(CancelPipelineReprocessingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelPipelineReprocessingRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelPipelineReprocessingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CreateChannelResponse CreateChannel(CreateChannelRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateChannelResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CreateChannelAsync(CreateChannelRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateChannelResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CreateDatasetResponse CreateDataset(CreateDatasetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatasetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CreateDatasetAsync(CreateDatasetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatasetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CreateDatasetContentResponse CreateDatasetContent(CreateDatasetContentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatasetContentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CreateDatasetContentAsync(CreateDatasetContentRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatasetContentResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CreateDatastoreResponse CreateDatastore(CreateDatastoreRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatastoreResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CreateDatastoreAsync(CreateDatastoreRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDatastoreResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual CreatePipelineResponse CreatePipeline(CreatePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task CreatePipelineAsync(CreatePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DeleteChannelResponse DeleteChannel(DeleteChannelRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteChannelResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DeleteChannelAsync(DeleteChannelRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteChannelResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DeleteDatasetResponse DeleteDataset(DeleteDatasetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatasetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DeleteDatasetAsync(DeleteDatasetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatasetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DeleteDatasetContentResponse DeleteDatasetContent(DeleteDatasetContentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatasetContentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DeleteDatasetContentAsync(DeleteDatasetContentRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatasetContentResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DeleteDatastoreResponse DeleteDatastore(DeleteDatastoreRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatastoreResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DeleteDatastoreAsync(DeleteDatastoreRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDatastoreResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DeletePipelineResponse DeletePipeline(DeletePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DeletePipelineAsync(DeletePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DescribeChannelResponse DescribeChannel(DescribeChannelRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeChannelResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DescribeChannelAsync(DescribeChannelRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeChannelResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DescribeDatasetResponse DescribeDataset(DescribeDatasetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDatasetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DescribeDatasetAsync(DescribeDatasetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDatasetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DescribeDatastoreResponse DescribeDatastore(DescribeDatastoreRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDatastoreResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DescribeDatastoreAsync(DescribeDatastoreRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDatastoreResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DescribeLoggingOptionsResponse DescribeLoggingOptions(DescribeLoggingOptionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeLoggingOptionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeLoggingOptionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DescribeLoggingOptionsAsync(DescribeLoggingOptionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeLoggingOptionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeLoggingOptionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual DescribePipelineResponse DescribePipeline(DescribePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task DescribePipelineAsync(DescribePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual GetDatasetContentResponse GetDatasetContent(GetDatasetContentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetDatasetContentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task GetDatasetContentAsync(GetDatasetContentRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetDatasetContentRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetDatasetContentResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListChannelsResponse ListChannels(ListChannelsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListChannelsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListChannelsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListChannelsAsync(ListChannelsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListChannelsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListChannelsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListDatasetContentsResponse ListDatasetContents(ListDatasetContentsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatasetContentsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatasetContentsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListDatasetContentsAsync(ListDatasetContentsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatasetContentsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatasetContentsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListDatasetsResponse ListDatasets(ListDatasetsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatasetsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatasetsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListDatasetsAsync(ListDatasetsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatasetsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatasetsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListDatastoresResponse ListDatastores(ListDatastoresRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatastoresRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatastoresResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListDatastoresAsync(ListDatastoresRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDatastoresRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDatastoresResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListPipelinesResponse ListPipelines(ListPipelinesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelinesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelinesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListPipelinesAsync(ListPipelinesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelinesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelinesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task ListTagsForResourceAsync(ListTagsForResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual PutLoggingOptionsResponse PutLoggingOptions(PutLoggingOptionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutLoggingOptionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutLoggingOptionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task PutLoggingOptionsAsync(PutLoggingOptionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutLoggingOptionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutLoggingOptionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual RunPipelineActivityResponse RunPipelineActivity(RunPipelineActivityRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RunPipelineActivityRequestMarshaller.Instance;
options.ResponseUnmarshaller = RunPipelineActivityResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task RunPipelineActivityAsync(RunPipelineActivityRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RunPipelineActivityRequestMarshaller.Instance;
options.ResponseUnmarshaller = RunPipelineActivityResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual SampleChannelDataResponse SampleChannelData(SampleChannelDataRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = SampleChannelDataRequestMarshaller.Instance;
options.ResponseUnmarshaller = SampleChannelDataResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task SampleChannelDataAsync(SampleChannelDataRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = SampleChannelDataRequestMarshaller.Instance;
options.ResponseUnmarshaller = SampleChannelDataResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual StartPipelineReprocessingResponse StartPipelineReprocessing(StartPipelineReprocessingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipelineReprocessingRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipelineReprocessingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task StartPipelineReprocessingAsync(StartPipelineReprocessingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipelineReprocessingRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipelineReprocessingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task TagResourceAsync(TagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task UntagResourceAsync(UntagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual UpdateChannelResponse UpdateChannel(UpdateChannelRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateChannelResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task UpdateChannelAsync(UpdateChannelRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateChannelRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateChannelResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual UpdateDatasetResponse UpdateDataset(UpdateDatasetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDatasetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task UpdateDatasetAsync(UpdateDatasetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDatasetRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDatasetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual UpdateDatastoreResponse UpdateDatastore(UpdateDatastoreRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDatastoreResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task UpdateDatastoreAsync(UpdateDatastoreRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDatastoreRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDatastoreResponseUnmarshaller.Instance;
return InvokeAsync(request, options, 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
public virtual UpdatePipelineResponse UpdatePipeline(UpdatePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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
public virtual Task UpdatePipelineAsync(UpdatePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}