Struct aws_sdk_iotanalytics::Client

impl Client

pub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self

Creates a client with the given service configuration.

Examples found in repository ?

src/client.rs (line 70)

    fn from(
        client: aws_smithy_client::Client<
            aws_smithy_client::erase::DynConnector,
            aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
        >,
    ) -> Self {
        Self::with_config(client, crate::Config::builder().build())
    }

pub fn conf(&self) -> &Config

Returns the client’s configuration.

impl Client

pub fn batch_put_message(&self) -> BatchPutMessage

Constructs a fluent builder for the BatchPutMessage operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel where the messages are sent.
- messages(Vec<Message>) / set_messages(Option<Vec<Message>>):
 The list of messages to be sent. Each message has the format: { “messageId”: “string”, “payload”: “string”}.
 
 The field names of message payloads (data) that you send to IoT Analytics:
 - Must contain only alphanumeric characters and undescores (). No other special characters are allowed.
 - Must begin with an alphabetic character or single underscore ().
 - Cannot contain hyphens (-).
 - In regular expression terms: “^A-Za-z_$”.
 - Cannot be more than 255 characters.
 - Are case insensitive. (Fields named foo and FOO in the same payload are considered duplicates.)
 For example, {“temp_01”: 29} or {“_temp_01”: 29} are valid, but {“temp-01”: 29}, {“01_temp”: 29} or {“__temp_01”: 29} are invalid in message payloads.
On success, responds with BatchPutMessageOutput with field(s):
- batch_put_message_error_entries(Option<Vec<BatchPutMessageErrorEntry>>):
 A list of any errors encountered when sending the messages to the channel.
On failure, responds with SdkError<BatchPutMessageError>

pub fn cancel_pipeline_reprocessing(&self) -> CancelPipelineReprocessing

Constructs a fluent builder for the CancelPipelineReprocessing operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of pipeline for which data reprocessing is canceled.
- reprocessing_id(impl Into<String>) / set_reprocessing_id(Option<String>):
 The ID of the reprocessing task (returned by StartPipelineReprocessing).
On success, responds with CancelPipelineReprocessingOutput
On failure, responds with SdkError<CancelPipelineReprocessingError>

pub fn create_channel(&self) -> CreateChannel

Constructs a fluent builder for the CreateChannel operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel.
- channel_storage(ChannelStorage) / set_channel_storage(Option<ChannelStorage>):
 Where channel data is stored. You can choose one of serviceManagedS3 or customerManagedS3 storage. If not specified, the default is serviceManagedS3. You can’t change this storage option after the channel is created.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the channel. When customerManagedS3 storage is selected, this parameter is ignored.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 Metadata which can be used to manage the channel.
On success, responds with CreateChannelOutput with field(s):
- channel_name(Option<String>):
 The name of the channel.
- channel_arn(Option<String>):
 The ARN of the channel.
- retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the channel.
On failure, responds with SdkError<CreateChannelError>

pub fn create_dataset(&self) -> CreateDataset

Constructs a fluent builder for the CreateDataset operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset.
- actions(Vec<DatasetAction>) / set_actions(Option<Vec<DatasetAction>>):
 A list of actions that create the dataset contents.
- triggers(Vec<DatasetTrigger>) / set_triggers(Option<Vec<DatasetTrigger>>):
 A list of triggers. A trigger causes dataset contents to be populated at a specified time interval or when another dataset’s contents are created. The list of triggers can be empty or contain up to five DataSetTrigger objects.
- content_delivery_rules(Vec<DatasetContentDeliveryRule>) / set_content_delivery_rules(Option<Vec<DatasetContentDeliveryRule>>):
 When dataset contents are created, they are delivered to destinations specified here.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 Optional. How long, in days, versions of dataset contents are kept for the dataset. If not specified or set to null, versions of dataset contents are retained for at most 90 days. The number of versions of dataset contents retained is determined by the versioningConfiguration parameter. For more information, see Keeping Multiple Versions of IoT Analytics datasets in the IoT Analytics User Guide.
- versioning_configuration(VersioningConfiguration) / set_versioning_configuration(Option<VersioningConfiguration>):
 Optional. How many versions of dataset contents are kept. If not specified or set to null, only the latest version plus the latest succeeded version (if they are different) are kept for the time period specified by the retentionPeriod parameter. For more information, see Keeping Multiple Versions of IoT Analytics datasets in the IoT Analytics User Guide.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 Metadata which can be used to manage the dataset.
- late_data_rules(Vec<LateDataRule>) / set_late_data_rules(Option<Vec<LateDataRule>>):
 A list of data rules that send notifications to CloudWatch, when data arrives late. To specify lateDataRules, the dataset must use a DeltaTimer filter.
On success, responds with CreateDatasetOutput with field(s):
- dataset_name(Option<String>):
 The name of the dataset.
- dataset_arn(Option<String>):
 The ARN of the dataset.
- retention_period(Option<RetentionPeriod>):
 How long, in days, dataset contents are kept for the dataset.
On failure, responds with SdkError<CreateDatasetError>

pub fn create_dataset_content(&self) -> CreateDatasetContent

Constructs a fluent builder for the CreateDatasetContent operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset.
- version_id(impl Into<String>) / set_version_id(Option<String>):
 The version ID of the dataset content. To specify versionId for a dataset content, the dataset must use a DeltaTimer filter.
On success, responds with CreateDatasetContentOutput with field(s):
- version_id(Option<String>):
 The version ID of the dataset contents that are being created.
On failure, responds with SdkError<CreateDatasetContentError>

pub fn create_datastore(&self) -> CreateDatastore

Constructs a fluent builder for the CreateDatastore operation.

The fluent builder is configurable:
- datastore_name(impl Into<String>) / set_datastore_name(Option<String>):
 The name of the data store.
- datastore_storage(DatastoreStorage) / set_datastore_storage(Option<DatastoreStorage>):
 Where data in a data store is stored.. You can choose serviceManagedS3 storage, customerManagedS3 storage, or iotSiteWiseMultiLayerStorage storage. The default is serviceManagedS3. You can’t change the choice of Amazon S3 storage after your data store is created.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the data store. When customerManagedS3 storage is selected, this parameter is ignored.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 Metadata which can be used to manage the data store.
- file_format_configuration(FileFormatConfiguration) / set_file_format_configuration(Option<FileFormatConfiguration>):
 Contains the configuration information of file formats. IoT Analytics data stores support JSON and Parquet.
 
 The default file format is JSON. You can specify only one format.
 
 You can’t change the file format after you create the data store.
- datastore_partitions(DatastorePartitions) / set_datastore_partitions(Option<DatastorePartitions>):
 Contains information about the partition dimensions in a data store.
On success, responds with CreateDatastoreOutput with field(s):
- datastore_name(Option<String>):
 The name of the data store.
- datastore_arn(Option<String>):
 The ARN of the data store.
- retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the data store.
On failure, responds with SdkError<CreateDatastoreError>

pub fn create_pipeline(&self) -> CreatePipeline

Constructs a fluent builder for the CreatePipeline operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of the pipeline.
- pipeline_activities(Vec<PipelineActivity>) / set_pipeline_activities(Option<Vec<PipelineActivity>>):
 A list of PipelineActivity objects. Activities perform transformations on your messages, such as removing, renaming or adding message attributes; filtering messages based on attribute values; invoking your Lambda unctions on messages for advanced processing; or performing mathematical transformations to normalize device data.
 
 The list can be 2-25 PipelineActivity objects and must contain both a channel and a datastore activity. Each entry in the list must contain only one activity. For example:
 
 pipelineActivities = [ { “channel”: { … } }, { “lambda”: { … } }, … ]
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 Metadata which can be used to manage the pipeline.
On success, responds with CreatePipelineOutput with field(s):
- pipeline_name(Option<String>):
 The name of the pipeline.
- pipeline_arn(Option<String>):
 The ARN of the pipeline.
On failure, responds with SdkError<CreatePipelineError>

pub fn delete_channel(&self) -> DeleteChannel

Constructs a fluent builder for the DeleteChannel operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel to delete.
On success, responds with DeleteChannelOutput
On failure, responds with SdkError<DeleteChannelError>

pub fn delete_dataset(&self) -> DeleteDataset

Constructs a fluent builder for the DeleteDataset operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset to delete.
On success, responds with DeleteDatasetOutput
On failure, responds with SdkError<DeleteDatasetError>

pub fn delete_dataset_content(&self) -> DeleteDatasetContent

Constructs a fluent builder for the DeleteDatasetContent operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset whose content is deleted.
- version_id(impl Into<String>) / set_version_id(Option<String>):
 The version of the dataset whose content is deleted. You can also use the strings “$LATEST” or “$LATEST_SUCCEEDED” to delete the latest or latest successfully completed data set. If not specified, “$LATEST_SUCCEEDED” is the default.
On success, responds with DeleteDatasetContentOutput
On failure, responds with SdkError<DeleteDatasetContentError>

pub fn delete_datastore(&self) -> DeleteDatastore

Constructs a fluent builder for the DeleteDatastore operation.

The fluent builder is configurable:
- datastore_name(impl Into<String>) / set_datastore_name(Option<String>):
 The name of the data store to delete.
On success, responds with DeleteDatastoreOutput
On failure, responds with SdkError<DeleteDatastoreError>

pub fn delete_pipeline(&self) -> DeletePipeline

Constructs a fluent builder for the DeletePipeline operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of the pipeline to delete.
On success, responds with DeletePipelineOutput
On failure, responds with SdkError<DeletePipelineError>

pub fn describe_channel(&self) -> DescribeChannel

Constructs a fluent builder for the DescribeChannel operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel whose information is retrieved.
- include_statistics(bool) / set_include_statistics(bool):
 If true, additional statistical information about the channel is included in the response. This feature can’t be used with a channel whose S3 storage is customer-managed.
On success, responds with DescribeChannelOutput with field(s):
- channel(Option<Channel>):
 An object that contains information about the channel.
- statistics(Option<ChannelStatistics>):
 Statistics about the channel. Included if the includeStatistics parameter is set to true in the request.
On failure, responds with SdkError<DescribeChannelError>

pub fn describe_dataset(&self) -> DescribeDataset

Constructs a fluent builder for the DescribeDataset operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset whose information is retrieved.
On success, responds with DescribeDatasetOutput with field(s):
- dataset(Option<Dataset>):
 An object that contains information about the dataset.
On failure, responds with SdkError<DescribeDatasetError>

pub fn describe_datastore(&self) -> DescribeDatastore

Constructs a fluent builder for the DescribeDatastore operation.

The fluent builder is configurable:
- datastore_name(impl Into<String>) / set_datastore_name(Option<String>):
 The name of the data store
- include_statistics(bool) / set_include_statistics(bool):
 If true, additional statistical information about the data store is included in the response. This feature can’t be used with a data store whose S3 storage is customer-managed.
On success, responds with DescribeDatastoreOutput with field(s):
- datastore(Option<Datastore>):
 Information about the data store.
- statistics(Option<DatastoreStatistics>):
 Additional statistical information about the data store. Included if the includeStatistics parameter is set to true in the request.
On failure, responds with SdkError<DescribeDatastoreError>

pub fn describe_logging_options(&self) -> DescribeLoggingOptions

Constructs a fluent builder for the DescribeLoggingOptions operation.

The fluent builder takes no input, just send it.
On success, responds with DescribeLoggingOptionsOutput with field(s):
- logging_options(Option<LoggingOptions>):
 The current settings of the IoT Analytics logging options.
On failure, responds with SdkError<DescribeLoggingOptionsError>

pub fn describe_pipeline(&self) -> DescribePipeline

Constructs a fluent builder for the DescribePipeline operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of the pipeline whose information is retrieved.
On success, responds with DescribePipelineOutput with field(s):
- pipeline(Option<Pipeline>):
 A Pipeline object that contains information about the pipeline.
On failure, responds with SdkError<DescribePipelineError>

pub fn get_dataset_content(&self) -> GetDatasetContent

Constructs a fluent builder for the GetDatasetContent operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset whose contents are retrieved.
- version_id(impl Into<String>) / set_version_id(Option<String>):
 The version of the dataset whose contents are retrieved. You can also use the strings “$LATEST” or “$LATEST_SUCCEEDED” to retrieve the contents of the latest or latest successfully completed dataset. If not specified, “$LATEST_SUCCEEDED” is the default.
On success, responds with GetDatasetContentOutput with field(s):
- entries(Option<Vec<DatasetEntry>>):
 A list of DatasetEntry objects.
- timestamp(Option<DateTime>):
 The time when the request was made.
- status(Option<DatasetContentStatus>):
 The status of the dataset content.
On failure, responds with SdkError<GetDatasetContentError>

pub fn list_channels(&self) -> ListChannels

Constructs a fluent builder for the ListChannels operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
 The token for the next set of results.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of results to return in this request.
 
 The default value is 100.
On success, responds with ListChannelsOutput with field(s):
- channel_summaries(Option<Vec<ChannelSummary>>):
 A list of ChannelSummary objects.
- next_token(Option<String>):
 The token to retrieve the next set of results, or null if there are no more results.
On failure, responds with SdkError<ListChannelsError>

pub fn list_dataset_contents(&self) -> ListDatasetContents

Constructs a fluent builder for the ListDatasetContents operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset whose contents information you want to list.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 The token for the next set of results.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of results to return in this request.
- scheduled_on_or_after(DateTime) / set_scheduled_on_or_after(Option<DateTime>):
 A filter to limit results to those dataset contents whose creation is scheduled on or after the given time. See the field triggers.schedule in the CreateDataset request. (timestamp)
- scheduled_before(DateTime) / set_scheduled_before(Option<DateTime>):
 A filter to limit results to those dataset contents whose creation is scheduled before the given time. See the field triggers.schedule in the CreateDataset request. (timestamp)
On success, responds with ListDatasetContentsOutput with field(s):
- dataset_content_summaries(Option<Vec<DatasetContentSummary>>):
 Summary information about dataset contents that have been created.
- next_token(Option<String>):
 The token to retrieve the next set of results, or null if there are no more results.
On failure, responds with SdkError<ListDatasetContentsError>

pub fn list_datasets(&self) -> ListDatasets

Constructs a fluent builder for the ListDatasets operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
 The token for the next set of results.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of results to return in this request.
 
 The default value is 100.
On success, responds with ListDatasetsOutput with field(s):
- dataset_summaries(Option<Vec<DatasetSummary>>):
 A list of DatasetSummary objects.
- next_token(Option<String>):
 The token to retrieve the next set of results, or null if there are no more results.
On failure, responds with SdkError<ListDatasetsError>

pub fn list_datastores(&self) -> ListDatastores

Constructs a fluent builder for the ListDatastores operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
 The token for the next set of results.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of results to return in this request.
 
 The default value is 100.
On success, responds with ListDatastoresOutput with field(s):
- datastore_summaries(Option<Vec<DatastoreSummary>>):
 A list of DatastoreSummary objects.
- next_token(Option<String>):
 The token to retrieve the next set of results, or null if there are no more results.
On failure, responds with SdkError<ListDatastoresError>

pub fn list_pipelines(&self) -> ListPipelines

Constructs a fluent builder for the ListPipelines operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
 The token for the next set of results.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of results to return in this request.
 
 The default value is 100.
On success, responds with ListPipelinesOutput with field(s):
- pipeline_summaries(Option<Vec<PipelineSummary>>):
 A list of PipelineSummary objects.
- next_token(Option<String>):
 The token to retrieve the next set of results, or null if there are no more results.
On failure, responds with SdkError<ListPipelinesError>

pub fn list_tags_for_resource(&self) -> ListTagsForResource

Constructs a fluent builder for the ListTagsForResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The ARN of the resource whose tags you want to list.
On success, responds with ListTagsForResourceOutput with field(s):
- tags(Option<Vec<Tag>>):
 The tags (metadata) that you have assigned to the resource.
On failure, responds with SdkError<ListTagsForResourceError>

pub fn put_logging_options(&self) -> PutLoggingOptions

Constructs a fluent builder for the PutLoggingOptions operation.

The fluent builder is configurable:
- logging_options(LoggingOptions) / set_logging_options(Option<LoggingOptions>):
 The new values of the IoT Analytics logging options.
On success, responds with PutLoggingOptionsOutput
On failure, responds with SdkError<PutLoggingOptionsError>

pub fn run_pipeline_activity(&self) -> RunPipelineActivity

Constructs a fluent builder for the RunPipelineActivity operation.

The fluent builder is configurable:
- pipeline_activity(PipelineActivity) / set_pipeline_activity(Option<PipelineActivity>):
 The pipeline activity that is run. This must not be a channel activity or a data store activity because these activities are used in a pipeline only to load the original message and to store the (possibly) transformed message. If a Lambda activity is specified, only short-running Lambda functions (those with a timeout of less than 30 seconds or less) can be used.
- payloads(Vec<Blob>) / set_payloads(Option<Vec<Blob>>):
 The sample message payloads on which the pipeline activity is run.
On success, responds with RunPipelineActivityOutput with field(s):
- payloads(Option<Vec<Blob>>):
 The enriched or transformed sample message payloads as base64-encoded strings. (The results of running the pipeline activity on each input sample message payload, encoded in base64.)
- log_result(Option<String>):
 In case the pipeline activity fails, the log message that is generated.
On failure, responds with SdkError<RunPipelineActivityError>

pub fn sample_channel_data(&self) -> SampleChannelData

Constructs a fluent builder for the SampleChannelData operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel whose message samples are retrieved.
- max_messages(i32) / set_max_messages(Option<i32>):
 The number of sample messages to be retrieved. The limit is 10. The default is also 10.
- start_time(DateTime) / set_start_time(Option<DateTime>):
 The start of the time window from which sample messages are retrieved.
- end_time(DateTime) / set_end_time(Option<DateTime>):
 The end of the time window from which sample messages are retrieved.
On success, responds with SampleChannelDataOutput with field(s):
- payloads(Option<Vec<Blob>>):
 The list of message samples. Each sample message is returned as a base64-encoded string.
On failure, responds with SdkError<SampleChannelDataError>

pub fn start_pipeline_reprocessing(&self) -> StartPipelineReprocessing

Constructs a fluent builder for the StartPipelineReprocessing operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of the pipeline on which to start reprocessing.
- start_time(DateTime) / set_start_time(Option<DateTime>):
 The start time (inclusive) of raw message data that is reprocessed.
 
 If you specify a value for the startTime parameter, you must not use the channelMessages object.
- end_time(DateTime) / set_end_time(Option<DateTime>):
 The end time (exclusive) of raw message data that is reprocessed.
 
 If you specify a value for the endTime parameter, you must not use the channelMessages object.
- channel_messages(ChannelMessages) / set_channel_messages(Option<ChannelMessages>):
 Specifies one or more sets of channel messages that you want to reprocess.
 
 If you use the channelMessages object, you must not specify a value for startTime and endTime.
On success, responds with StartPipelineReprocessingOutput with field(s):
- reprocessing_id(Option<String>):
 The ID of the pipeline reprocessing activity that was started.
On failure, responds with SdkError<StartPipelineReprocessingError>

pub fn tag_resource(&self) -> TagResource

Constructs a fluent builder for the TagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The ARN of the resource whose tags you want to modify.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 The new or modified tags for the resource.
On success, responds with TagResourceOutput
On failure, responds with SdkError<TagResourceError>

pub fn untag_resource(&self) -> UntagResource

Constructs a fluent builder for the UntagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The ARN of the resource whose tags you want to remove.
- tag_keys(Vec<String>) / set_tag_keys(Option<Vec<String>>):
 The keys of those tags which you want to remove.
On success, responds with UntagResourceOutput
On failure, responds with SdkError<UntagResourceError>

pub fn update_channel(&self) -> UpdateChannel

Constructs a fluent builder for the UpdateChannel operation.

The fluent builder is configurable:
- channel_name(impl Into<String>) / set_channel_name(Option<String>):
 The name of the channel to be updated.
- channel_storage(ChannelStorage) / set_channel_storage(Option<ChannelStorage>):
 Where channel data is stored. You can choose one of serviceManagedS3 or customerManagedS3 storage. If not specified, the default is serviceManagedS3. You can’t change this storage option after the channel is created.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the channel. The retention period can’t be updated if the channel’s Amazon S3 storage is customer-managed.
On success, responds with UpdateChannelOutput
On failure, responds with SdkError<UpdateChannelError>

pub fn update_dataset(&self) -> UpdateDataset

Constructs a fluent builder for the UpdateDataset operation.

The fluent builder is configurable:
- dataset_name(impl Into<String>) / set_dataset_name(Option<String>):
 The name of the dataset to update.
- actions(Vec<DatasetAction>) / set_actions(Option<Vec<DatasetAction>>):
 A list of DatasetAction objects.
- triggers(Vec<DatasetTrigger>) / set_triggers(Option<Vec<DatasetTrigger>>):
 A list of DatasetTrigger objects. The list can be empty or can contain up to five DatasetTrigger objects.
- content_delivery_rules(Vec<DatasetContentDeliveryRule>) / set_content_delivery_rules(Option<Vec<DatasetContentDeliveryRule>>):
 When dataset contents are created, they are delivered to destinations specified here.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 How long, in days, dataset contents are kept for the dataset.
- versioning_configuration(VersioningConfiguration) / set_versioning_configuration(Option<VersioningConfiguration>):
 Optional. How many versions of dataset contents are kept. If not specified or set to null, only the latest version plus the latest succeeded version (if they are different) are kept for the time period specified by the retentionPeriod parameter. For more information, see Keeping Multiple Versions of IoT Analytics datasets in the IoT Analytics User Guide.
- late_data_rules(Vec<LateDataRule>) / set_late_data_rules(Option<Vec<LateDataRule>>):
 A list of data rules that send notifications to CloudWatch, when data arrives late. To specify lateDataRules, the dataset must use a DeltaTimer filter.
On success, responds with UpdateDatasetOutput
On failure, responds with SdkError<UpdateDatasetError>

pub fn update_datastore(&self) -> UpdateDatastore

Constructs a fluent builder for the UpdateDatastore operation.

The fluent builder is configurable:
- datastore_name(impl Into<String>) / set_datastore_name(Option<String>):
 The name of the data store to be updated.
- retention_period(RetentionPeriod) / set_retention_period(Option<RetentionPeriod>):
 How long, in days, message data is kept for the data store. The retention period can’t be updated if the data store’s Amazon S3 storage is customer-managed.
- datastore_storage(DatastoreStorage) / set_datastore_storage(Option<DatastoreStorage>):
 Where data in a data store is stored.. You can choose serviceManagedS3 storage, customerManagedS3 storage, or iotSiteWiseMultiLayerStorage storage. The default is serviceManagedS3. You can’t change the choice of Amazon S3 storage after your data store is created.
- file_format_configuration(FileFormatConfiguration) / set_file_format_configuration(Option<FileFormatConfiguration>):
 Contains the configuration information of file formats. IoT Analytics data stores support JSON and Parquet.
 
 The default file format is JSON. You can specify only one format.
 
 You can’t change the file format after you create the data store.
On success, responds with UpdateDatastoreOutput
On failure, responds with SdkError<UpdateDatastoreError>

pub fn update_pipeline(&self) -> UpdatePipeline

Constructs a fluent builder for the UpdatePipeline operation.

The fluent builder is configurable:
- pipeline_name(impl Into<String>) / set_pipeline_name(Option<String>):
 The name of the pipeline to update.
- pipeline_activities(Vec<PipelineActivity>) / set_pipeline_activities(Option<Vec<PipelineActivity>>):
 A list of PipelineActivity objects. Activities perform transformations on your messages, such as removing, renaming or adding message attributes; filtering messages based on attribute values; invoking your Lambda functions on messages for advanced processing; or performing mathematical transformations to normalize device data.
 
 The list can be 2-25 PipelineActivity objects and must contain both a channel and a datastore activity. Each entry in the list must contain only one activity. For example:
 
 pipelineActivities = [ { “channel”: { … } }, { “lambda”: { … } }, … ]
On success, responds with UpdatePipelineOutput
On failure, responds with SdkError<UpdatePipelineError>

impl Client

pub fn new(sdk_config: &SdkConfig) -> Self

Creates a new client from an SDK Config.

Panics

This method will panic if the sdk_config is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
This method will panic if the sdk_config is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.

pub fn from_conf(conf: Config) -> Self

Creates a new client from the service Config.

Panics

This method will panic if the conf is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
This method will panic if the conf is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.

Examples found in repository ?

src/client.rs (line 3862)

3861
3862
3863

    pub fn new(sdk_config: &aws_types::sdk_config::SdkConfig) -> Self {
        Self::from_conf(sdk_config.into())
    }

Trait Implementations§

impl Clone for Client

fn clone(&self) -> Self

Returns a copy of the value. Read more

1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

impl From<Client<DynConnector, DynMiddleware<DynConnector>, Standard>> for Client

fn from(client: Client<DynConnector, DynMiddleware<DynConnector>>) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

impl !UnwindSafe for Client

Blanket Implementations§

impl<T> Any for Twhere
T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for Twhere
T: ?Sized,

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

const: unstable · source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into for Twhere
U: From<T>,

const: unstable · source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> ToOwned for Twhere
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom for Twhere
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source§

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

impl<T, U> TryInto for Twhere
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source§

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more