awsiotanalytics

package
v1.144.0-devpreview Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 8, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CfnChannel_CFN_RESOURCE_TYPE_NAME

func CfnChannel_CFN_RESOURCE_TYPE_NAME() *string

func CfnChannel_IsCfnElement

func CfnChannel_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnChannel_IsCfnResource

func CfnChannel_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnChannel_IsConstruct

func CfnChannel_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func CfnDataset_CFN_RESOURCE_TYPE_NAME

func CfnDataset_CFN_RESOURCE_TYPE_NAME() *string

func CfnDataset_IsCfnElement

func CfnDataset_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnDataset_IsCfnResource

func CfnDataset_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnDataset_IsConstruct

func CfnDataset_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func CfnDatastore_CFN_RESOURCE_TYPE_NAME

func CfnDatastore_CFN_RESOURCE_TYPE_NAME() *string

func CfnDatastore_IsCfnElement

func CfnDatastore_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnDatastore_IsCfnResource

func CfnDatastore_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnDatastore_IsConstruct

func CfnDatastore_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func CfnPipeline_CFN_RESOURCE_TYPE_NAME

func CfnPipeline_CFN_RESOURCE_TYPE_NAME() *string

func CfnPipeline_IsCfnElement

func CfnPipeline_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnPipeline_IsCfnResource

func CfnPipeline_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnPipeline_IsConstruct

func CfnPipeline_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func NewCfnChannel_Override

func NewCfnChannel_Override(c CfnChannel, scope awscdk.Construct, id *string, props *CfnChannelProps)

Create a new `AWS::IoTAnalytics::Channel`.

func NewCfnDataset_Override

func NewCfnDataset_Override(c CfnDataset, scope awscdk.Construct, id *string, props *CfnDatasetProps)

Create a new `AWS::IoTAnalytics::Dataset`.

func NewCfnDatastore_Override

func NewCfnDatastore_Override(c CfnDatastore, scope awscdk.Construct, id *string, props *CfnDatastoreProps)

Create a new `AWS::IoTAnalytics::Datastore`.

func NewCfnPipeline_Override

func NewCfnPipeline_Override(c CfnPipeline, scope awscdk.Construct, id *string, props *CfnPipelineProps)

Create a new `AWS::IoTAnalytics::Pipeline`.

Types

type CfnChannel

type CfnChannel interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrId() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	ChannelName() *string
	SetChannelName(val *string)
	ChannelStorage() interface{}
	SetChannelStorage(val interface{})
	CreationStack() *[]*string
	LogicalId() *string
	Node() awscdk.ConstructNode
	Ref() *string
	RetentionPeriod() interface{}
	SetRetentionPeriod(val interface{})
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::IoTAnalytics::Channel`.

The AWS::IoTAnalytics::Channel resource collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline. For more information, see [How to Use AWS IoT Analytics](https://docs.aws.amazon.com/iotanalytics/latest/userguide/welcome.html#aws-iot-analytics-how) in the *AWS IoT Analytics User Guide* .

TODO: EXAMPLE

func NewCfnChannel

func NewCfnChannel(scope awscdk.Construct, id *string, props *CfnChannelProps) CfnChannel

Create a new `AWS::IoTAnalytics::Channel`.

type CfnChannelProps

type CfnChannelProps struct {
	// The name of the channel.
	ChannelName *string `json:"channelName" yaml:"channelName"`
	// Where channel data is stored.
	ChannelStorage interface{} `json:"channelStorage" yaml:"channelStorage"`
	// How long, in days, message data is kept for the channel.
	RetentionPeriod interface{} `json:"retentionPeriod" yaml:"retentionPeriod"`
	// Metadata which can be used to manage the channel.
	//
	// For more information, see [Tag](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html) .
	Tags *[]*awscdk.CfnTag `json:"tags" yaml:"tags"`
}

Properties for defining a `CfnChannel`.

TODO: EXAMPLE

type CfnChannel_ChannelStorageProperty

type CfnChannel_ChannelStorageProperty struct {
	// Used to store channel data in an S3 bucket that you manage.
	//
	// If customer managed storage is selected, the `retentionPeriod` parameter is ignored. You can't change the choice of S3 storage after the data store is created.
	CustomerManagedS3 interface{} `json:"customerManagedS3" yaml:"customerManagedS3"`
	// Used to store channel data in an S3 bucket managed by AWS IoT Analytics .
	//
	// You can't change the choice of S3 storage after the data store is created.
	ServiceManagedS3 interface{} `json:"serviceManagedS3" yaml:"serviceManagedS3"`
}

Where channel data is stored.

You may choose one of `serviceManagedS3` , `customerManagedS3` storage. If not specified, the default is `serviceManagedS3` . This can't be changed after creation of the channel.

TODO: EXAMPLE

type CfnChannel_CustomerManagedS3Property

type CfnChannel_CustomerManagedS3Property struct {
	// The name of the S3 bucket in which channel data is stored.
	Bucket *string `json:"bucket" yaml:"bucket"`
	// The ARN of the role that grants AWS IoT Analytics permission to interact with your Amazon S3 resources.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
	// (Optional) The prefix used to create the keys of the channel data objects.
	//
	// Each object in an S3 bucket has a key that is its unique identifier within the bucket (each object in a bucket has exactly one key). The prefix must end with a forward slash (/).
	KeyPrefix *string `json:"keyPrefix" yaml:"keyPrefix"`
}

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

TODO: EXAMPLE

type CfnChannel_RetentionPeriodProperty

type CfnChannel_RetentionPeriodProperty struct {
	// The number of days that message data is kept.
	//
	// The `unlimited` parameter must be false.
	NumberOfDays *float64 `json:"numberOfDays" yaml:"numberOfDays"`
	// If true, message data is kept indefinitely.
	Unlimited interface{} `json:"unlimited" yaml:"unlimited"`
}

How long, in days, message data is kept.

TODO: EXAMPLE

type CfnDataset

type CfnDataset interface {
	awscdk.CfnResource
	awscdk.IInspectable
	Actions() interface{}
	SetActions(val interface{})
	AttrId() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	ContentDeliveryRules() interface{}
	SetContentDeliveryRules(val interface{})
	CreationStack() *[]*string
	DatasetName() *string
	SetDatasetName(val *string)
	LateDataRules() interface{}
	SetLateDataRules(val interface{})
	LogicalId() *string
	Node() awscdk.ConstructNode
	Ref() *string
	RetentionPeriod() interface{}
	SetRetentionPeriod(val interface{})
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	Triggers() interface{}
	SetTriggers(val interface{})
	UpdatedProperites() *map[string]interface{}
	VersioningConfiguration() interface{}
	SetVersioningConfiguration(val interface{})
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::IoTAnalytics::Dataset`.

The AWS::IoTAnalytics::Dataset resource stores data retrieved from a data store by applying a `queryAction` (an SQL query) or a `containerAction` (executing a containerized application). The data set can be populated manually by calling `CreateDatasetContent` or automatically according to a `trigger` you specify. For more information, see [How to Use AWS IoT Analytics](https://docs.aws.amazon.com/iotanalytics/latest/userguide/welcome.html#aws-iot-analytics-how) in the *AWS IoT Analytics User Guide* .

TODO: EXAMPLE

func NewCfnDataset

func NewCfnDataset(scope awscdk.Construct, id *string, props *CfnDatasetProps) CfnDataset

Create a new `AWS::IoTAnalytics::Dataset`.

type CfnDatasetProps

type CfnDatasetProps struct {
	// The `DatasetAction` objects that automatically create the dataset contents.
	Actions interface{} `json:"actions" yaml:"actions"`
	// When dataset contents are created they are delivered to destinations specified here.
	ContentDeliveryRules interface{} `json:"contentDeliveryRules" yaml:"contentDeliveryRules"`
	// The name of the dataset.
	DatasetName *string `json:"datasetName" yaml:"datasetName"`
	// A list of data rules that send notifications to CloudWatch, when data arrives late.
	//
	// To specify `lateDataRules` , the dataset must use a [DeltaTimer](https://docs.aws.amazon.com/iotanalytics/latest/APIReference/API_DeltaTime.html) filter.
	LateDataRules interface{} `json:"lateDataRules" yaml:"lateDataRules"`
	// Optional.
	//
	// How long, in days, message data is kept for the dataset.
	RetentionPeriod interface{} `json:"retentionPeriod" yaml:"retentionPeriod"`
	// Metadata which can be used to manage the data set.
	//
	// For more information, see [Tag](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html) .
	Tags *[]*awscdk.CfnTag `json:"tags" yaml:"tags"`
	// The `DatasetTrigger` objects that specify when the dataset is automatically updated.
	Triggers interface{} `json:"triggers" yaml:"triggers"`
	// 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 AWS IoT Analytics datasets](https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions) in the *AWS IoT Analytics User Guide* .
	VersioningConfiguration interface{} `json:"versioningConfiguration" yaml:"versioningConfiguration"`
}

Properties for defining a `CfnDataset`.

TODO: EXAMPLE

type CfnDataset_ActionProperty

type CfnDataset_ActionProperty struct {
	// The name of the data set action by which data set contents are automatically created.
	ActionName *string `json:"actionName" yaml:"actionName"`
	// Information which allows the system to run a containerized application in order to create the data set contents.
	//
	// The application must be in a Docker container along with any needed support libraries.
	ContainerAction interface{} `json:"containerAction" yaml:"containerAction"`
	// An "SqlQueryDatasetAction" object that uses an SQL query to automatically create data set contents.
	QueryAction interface{} `json:"queryAction" yaml:"queryAction"`
}

Information needed to run the "containerAction" to produce data set contents.

TODO: EXAMPLE

type CfnDataset_ContainerActionProperty

type CfnDataset_ContainerActionProperty struct {
	// The ARN of the role which gives permission to the system to access needed resources in order to run the "containerAction".
	//
	// This includes, at minimum, permission to retrieve the data set contents which are the input to the containerized application.
	ExecutionRoleArn *string `json:"executionRoleArn" yaml:"executionRoleArn"`
	// The ARN of the Docker container stored in your account.
	//
	// The Docker container contains an application and needed support libraries and is used to generate data set contents.
	Image *string `json:"image" yaml:"image"`
	// Configuration of the resource which executes the "containerAction".
	ResourceConfiguration interface{} `json:"resourceConfiguration" yaml:"resourceConfiguration"`
	// The values of variables used within the context of the execution of the containerized application (basically, parameters passed to the application).
	//
	// Each variable must have a name and a value given by one of "stringValue", "datasetContentVersionValue", or "outputFileUriValue".
	Variables interface{} `json:"variables" yaml:"variables"`
}

Information needed to run the "containerAction" to produce data set contents.

TODO: EXAMPLE

type CfnDataset_DatasetContentDeliveryRuleDestinationProperty

type CfnDataset_DatasetContentDeliveryRuleDestinationProperty struct {
	// Configuration information for delivery of dataset contents to AWS IoT Events .
	IotEventsDestinationConfiguration interface{} `json:"iotEventsDestinationConfiguration" yaml:"iotEventsDestinationConfiguration"`
	// Configuration information for delivery of dataset contents to Amazon S3.
	S3DestinationConfiguration interface{} `json:"s3DestinationConfiguration" yaml:"s3DestinationConfiguration"`
}

The destination to which dataset contents are delivered.

TODO: EXAMPLE

type CfnDataset_DatasetContentDeliveryRuleProperty

type CfnDataset_DatasetContentDeliveryRuleProperty struct {
	// The destination to which dataset contents are delivered.
	Destination interface{} `json:"destination" yaml:"destination"`
	// The name of the dataset content delivery rules entry.
	EntryName *string `json:"entryName" yaml:"entryName"`
}

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

TODO: EXAMPLE

type CfnDataset_DatasetContentVersionValueProperty

type CfnDataset_DatasetContentVersionValueProperty struct {
	// The name of the dataset whose latest contents are used as input to the notebook or application.
	DatasetName *string `json:"datasetName" yaml:"datasetName"`
}

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

TODO: EXAMPLE

type CfnDataset_DeltaTimeProperty

type CfnDataset_DeltaTimeProperty struct {
	// The number of seconds of estimated in-flight lag time of message data.
	//
	// When you create dataset contents using message data from a specified timeframe, some message data might still be in flight when processing begins, and so do not arrive in time to be processed. Use this field to make allowances for the in flight time of your message data, so that data not processed from a previous timeframe is included with the next timeframe. Otherwise, missed message data would be excluded from processing during the next timeframe too, because its timestamp places it within the previous timeframe.
	OffsetSeconds *float64 `json:"offsetSeconds" yaml:"offsetSeconds"`
	// An expression by which the time of the message data might be determined.
	//
	// This can be the name of a timestamp field or a SQL expression that is used to derive the time the message data was generated.
	TimeExpression *string `json:"timeExpression" yaml:"timeExpression"`
}

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

TODO: EXAMPLE

type CfnDataset_DeltaTimeSessionWindowConfigurationProperty

type CfnDataset_DeltaTimeSessionWindowConfigurationProperty struct {
	// A time interval.
	//
	// You can use `timeoutInMinutes` so that AWS IoT Analytics can batch up late data notifications that have been generated since the last execution. AWS IoT Analytics sends one batch of notifications to Amazon CloudWatch Events at one time.
	//
	// For more information about how to write a timestamp expression, see [Date and Time Functions and Operators](https://docs.aws.amazon.com/https://prestodb.io/docs/0.172/functions/datetime.html) , in the *Presto 0.172 Documentation* .
	TimeoutInMinutes *float64 `json:"timeoutInMinutes" yaml:"timeoutInMinutes"`
}

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

[`DeltaTime`](https://docs.aws.amazon.com/iotanalytics/latest/APIReference/API_DeltaTime.html) specifies a time interval. You can use `DeltaTime` to create dataset contents with data that has arrived in the data store since the last execution. For an example of `DeltaTime` , see [Creating a SQL dataset with a delta window (CLI)](https://docs.aws.amazon.com/iotanalytics/latest/userguide/automate-create-dataset.html#automate-example6) in the *AWS IoT Analytics User Guide* .

TODO: EXAMPLE

type CfnDataset_FilterProperty

type CfnDataset_FilterProperty struct {
	// Used to limit data to that which has arrived since the last execution of the action.
	DeltaTime interface{} `json:"deltaTime" yaml:"deltaTime"`
}

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

TODO: EXAMPLE

type CfnDataset_GlueConfigurationProperty

type CfnDataset_GlueConfigurationProperty struct {
	// The name of the database in your AWS Glue Data Catalog in which the table is located.
	//
	// An AWS Glue Data Catalog database contains metadata tables.
	DatabaseName *string `json:"databaseName" yaml:"databaseName"`
	// The name of the table in your AWS Glue Data Catalog that is used to perform the ETL operations.
	//
	// An AWS Glue Data Catalog table contains partitioned data and descriptions of data sources and targets.
	TableName *string `json:"tableName" yaml:"tableName"`
}

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

TODO: EXAMPLE

type CfnDataset_IotEventsDestinationConfigurationProperty

type CfnDataset_IotEventsDestinationConfigurationProperty struct {
	// The name of the AWS IoT Events input to which dataset contents are delivered.
	InputName *string `json:"inputName" yaml:"inputName"`
	// The ARN of the role that grants AWS IoT Analytics permission to deliver dataset contents to an AWS IoT Events input.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

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

TODO: EXAMPLE

type CfnDataset_LateDataRuleConfigurationProperty

type CfnDataset_LateDataRuleConfigurationProperty struct {
	// The information needed to configure a delta time session window.
	DeltaTimeSessionWindowConfiguration interface{} `json:"deltaTimeSessionWindowConfiguration" yaml:"deltaTimeSessionWindowConfiguration"`
}

The information needed to configure a delta time session window.

TODO: EXAMPLE

type CfnDataset_LateDataRuleProperty

type CfnDataset_LateDataRuleProperty struct {
	// The information needed to configure the late data rule.
	RuleConfiguration interface{} `json:"ruleConfiguration" yaml:"ruleConfiguration"`
	// The name of the late data rule.
	RuleName *string `json:"ruleName" yaml:"ruleName"`
}

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

TODO: EXAMPLE

type CfnDataset_OutputFileUriValueProperty

type CfnDataset_OutputFileUriValueProperty struct {
	// The URI of the location where dataset contents are stored, usually the URI of a file in an S3 bucket.
	FileName *string `json:"fileName" yaml:"fileName"`
}

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

TODO: EXAMPLE

type CfnDataset_QueryActionProperty

type CfnDataset_QueryActionProperty struct {
	// An "SqlQueryDatasetAction" object that uses an SQL query to automatically create data set contents.
	SqlQuery *string `json:"sqlQuery" yaml:"sqlQuery"`
	// Pre-filters applied to message data.
	Filters interface{} `json:"filters" yaml:"filters"`
}

An "SqlQueryDatasetAction" object that uses an SQL query to automatically create data set contents.

TODO: EXAMPLE

type CfnDataset_ResourceConfigurationProperty

type CfnDataset_ResourceConfigurationProperty struct {
	// The type of the compute resource used to execute the `containerAction` .
	//
	// Possible values are: `ACU_1` (vCPU=4, memory=16 GiB) or `ACU_2` (vCPU=8, memory=32 GiB).
	ComputeType *string `json:"computeType" yaml:"computeType"`
	// The size, in GB, of the persistent storage available to the resource instance used to execute the `containerAction` (min: 1, max: 50).
	VolumeSizeInGb *float64 `json:"volumeSizeInGb" yaml:"volumeSizeInGb"`
}

The configuration of the resource used to execute the `containerAction` .

TODO: EXAMPLE

type CfnDataset_RetentionPeriodProperty

type CfnDataset_RetentionPeriodProperty struct {
	// The number of days that message data is kept.
	//
	// The `unlimited` parameter must be false.
	NumberOfDays *float64 `json:"numberOfDays" yaml:"numberOfDays"`
	// If true, message data is kept indefinitely.
	Unlimited interface{} `json:"unlimited" yaml:"unlimited"`
}

How long, in days, message data is kept.

TODO: EXAMPLE

type CfnDataset_S3DestinationConfigurationProperty

type CfnDataset_S3DestinationConfigurationProperty struct {
	// The name of the S3 bucket to which dataset contents are delivered.
	Bucket *string `json:"bucket" yaml:"bucket"`
	// The key of the dataset contents object in an S3 bucket.
	//
	// Each object has a key that is a unique identifier. Each object has exactly one key.
	//
	// You can create a unique key with the following options:
	//
	// - Use `!{iotanalytics:scheduleTime}` to insert the time of a scheduled SQL query run.
	// - Use `!{iotanalytics:versionId}` to insert a unique hash that identifies a dataset content.
	// - Use `!{iotanalytics:creationTime}` to insert the creation time of a dataset content.
	//
	// The following example creates a unique key for a CSV file: `dataset/mydataset/!{iotanalytics:scheduleTime}/!{iotanalytics:versionId}.csv`
	//
	// > If you don't use `!{iotanalytics:versionId}` to specify the key, you might get duplicate keys. For example, you might have two dataset contents with the same `scheduleTime` but different `versionId` s. This means that one dataset content overwrites the other.
	Key *string `json:"key" yaml:"key"`
	// The ARN of the role that grants AWS IoT Analytics permission to interact with your Amazon S3 and AWS Glue resources.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
	// Configuration information for coordination with AWS Glue , a fully managed extract, transform and load (ETL) service.
	GlueConfiguration interface{} `json:"glueConfiguration" yaml:"glueConfiguration"`
}

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

TODO: EXAMPLE

type CfnDataset_ScheduleProperty

type CfnDataset_ScheduleProperty struct {
	// The expression that defines when to trigger an update.
	//
	// For more information, see [Schedule Expressions for Rules](https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/ScheduledEvents.html) in the Amazon CloudWatch documentation.
	ScheduleExpression *string `json:"scheduleExpression" yaml:"scheduleExpression"`
}

The schedule for when to trigger an update.

TODO: EXAMPLE

type CfnDataset_TriggerProperty

type CfnDataset_TriggerProperty struct {
	// The "Schedule" when the trigger is initiated.
	Schedule interface{} `json:"schedule" yaml:"schedule"`
	// Information about the data set whose content generation triggers the new data set content generation.
	TriggeringDataset interface{} `json:"triggeringDataset" yaml:"triggeringDataset"`
}

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

TODO: EXAMPLE

type CfnDataset_TriggeringDatasetProperty

type CfnDataset_TriggeringDatasetProperty struct {
	// The name of the data set whose content generation triggers the new data set content generation.
	DatasetName *string `json:"datasetName" yaml:"datasetName"`
}

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

TODO: EXAMPLE

type CfnDataset_VariableProperty

type CfnDataset_VariableProperty struct {
	// The name of the variable.
	VariableName *string `json:"variableName" yaml:"variableName"`
	// The value of the variable as a structure that specifies a dataset content version.
	DatasetContentVersionValue interface{} `json:"datasetContentVersionValue" yaml:"datasetContentVersionValue"`
	// The value of the variable as a double (numeric).
	DoubleValue *float64 `json:"doubleValue" yaml:"doubleValue"`
	// The value of the variable as a structure that specifies an output file URI.
	OutputFileUriValue interface{} `json:"outputFileUriValue" yaml:"outputFileUriValue"`
	// The value of the variable as a string.
	StringValue *string `json:"stringValue" yaml:"stringValue"`
}

An instance of a variable to be passed to the `containerAction` execution.

Each variable must have a name and a value given by one of `stringValue` , `datasetContentVersionValue` , or `outputFileUriValue` .

TODO: EXAMPLE

type CfnDataset_VersioningConfigurationProperty

type CfnDataset_VersioningConfigurationProperty struct {
	// How many versions of dataset contents are kept.
	//
	// The `unlimited` parameter must be `false` .
	MaxVersions *float64 `json:"maxVersions" yaml:"maxVersions"`
	// If true, unlimited versions of dataset contents are kept.
	Unlimited interface{} `json:"unlimited" yaml:"unlimited"`
}

Information about the versioning of dataset contents.

TODO: EXAMPLE

type CfnDatastore

type CfnDatastore interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrId() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	DatastoreName() *string
	SetDatastoreName(val *string)
	DatastorePartitions() interface{}
	SetDatastorePartitions(val interface{})
	DatastoreStorage() interface{}
	SetDatastoreStorage(val interface{})
	FileFormatConfiguration() interface{}
	SetFileFormatConfiguration(val interface{})
	LogicalId() *string
	Node() awscdk.ConstructNode
	Ref() *string
	RetentionPeriod() interface{}
	SetRetentionPeriod(val interface{})
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::IoTAnalytics::Datastore`.

AWS::IoTAnalytics::Datastore resource is a repository for messages. For more information, see [How to Use AWS IoT Analytics](https://docs.aws.amazon.com/iotanalytics/latest/userguide/welcome.html#aws-iot-analytics-how) in the *AWS IoT Analytics User Guide* .

TODO: EXAMPLE

func NewCfnDatastore

func NewCfnDatastore(scope awscdk.Construct, id *string, props *CfnDatastoreProps) CfnDatastore

Create a new `AWS::IoTAnalytics::Datastore`.

type CfnDatastoreProps

type CfnDatastoreProps struct {
	// The name of the data store.
	DatastoreName *string `json:"datastoreName" yaml:"datastoreName"`
	// Information about the partition dimensions in a data store.
	DatastorePartitions interface{} `json:"datastorePartitions" yaml:"datastorePartitions"`
	// Where data store data is stored.
	DatastoreStorage interface{} `json:"datastoreStorage" yaml:"datastoreStorage"`
	// Contains the configuration information of file formats. AWS IoT Analytics data stores support JSON and [Parquet](https://docs.aws.amazon.com/https://parquet.apache.org/) .
	//
	// 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.
	FileFormatConfiguration interface{} `json:"fileFormatConfiguration" yaml:"fileFormatConfiguration"`
	// How long, in days, message data is kept for the data store.
	//
	// When `customerManagedS3` storage is selected, this parameter is ignored.
	RetentionPeriod interface{} `json:"retentionPeriod" yaml:"retentionPeriod"`
	// Metadata which can be used to manage the data store.
	//
	// For more information, see [Tag](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html) .
	Tags *[]*awscdk.CfnTag `json:"tags" yaml:"tags"`
}

Properties for defining a `CfnDatastore`.

TODO: EXAMPLE

type CfnDatastore_ColumnProperty

type CfnDatastore_ColumnProperty struct {
	// The name of the column.
	Name *string `json:"name" yaml:"name"`
	// The type of data.
	//
	// For more information about the supported data types, see [Common data types](https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-common.html) in the *AWS Glue Developer Guide* .
	Type *string `json:"type" yaml:"type"`
}

Contains information about a column that stores your data.

TODO: EXAMPLE

type CfnDatastore_CustomerManagedS3Property

type CfnDatastore_CustomerManagedS3Property struct {
	// The name of the Amazon S3 bucket where your data is stored.
	Bucket *string `json:"bucket" yaml:"bucket"`
	// The ARN of the role that grants AWS IoT Analytics permission to interact with your Amazon S3 resources.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
	// (Optional) The prefix used to create the keys of the data store data objects.
	//
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in the bucket. Each object in a bucket has exactly one key. The prefix must end with a forward slash (/).
	KeyPrefix *string `json:"keyPrefix" yaml:"keyPrefix"`
}

S3-customer-managed;

When you choose customer-managed storage, the `retentionPeriod` parameter is ignored. You can't change the choice of Amazon S3 storage after your data store is created.

TODO: EXAMPLE

type CfnDatastore_CustomerManagedS3StorageProperty

type CfnDatastore_CustomerManagedS3StorageProperty struct {
	// The name of the Amazon S3 bucket where your data is stored.
	Bucket *string `json:"bucket" yaml:"bucket"`
	// (Optional) The prefix used to create the keys of the data store data objects.
	//
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in the bucket. Each object in a bucket has exactly one key. The prefix must end with a forward slash (/).
	KeyPrefix *string `json:"keyPrefix" yaml:"keyPrefix"`
}

Amazon S3 -customer-managed;

When you choose customer-managed storage, the `retentionPeriod` parameter is ignored. You can't change the choice of Amazon S3 storage after your data store is created.

TODO: EXAMPLE

type CfnDatastore_DatastorePartitionProperty

type CfnDatastore_DatastorePartitionProperty struct {
	// A partition dimension defined by an attribute.
	Partition interface{} `json:"partition" yaml:"partition"`
	// A partition dimension defined by a timestamp attribute.
	TimestampPartition interface{} `json:"timestampPartition" yaml:"timestampPartition"`
}

A single dimension to partition a data store.

The dimension must be an `AttributePartition` or a `TimestampPartition` .

TODO: EXAMPLE

type CfnDatastore_DatastorePartitionsProperty

type CfnDatastore_DatastorePartitionsProperty struct {
	// A list of partition dimensions in a data store.
	Partitions interface{} `json:"partitions" yaml:"partitions"`
}

Information about the partition dimensions in a data store.

TODO: EXAMPLE

type CfnDatastore_DatastoreStorageProperty

type CfnDatastore_DatastoreStorageProperty struct {
	// Use this to store data store data in an S3 bucket that you manage.
	//
	// The choice of service-managed or customer-managed S3 storage cannot be changed after creation of the data store.
	CustomerManagedS3 interface{} `json:"customerManagedS3" yaml:"customerManagedS3"`
	// Use this to store data used by AWS IoT SiteWise in an Amazon S3 bucket that you manage.
	//
	// You can't change the choice of Amazon S3 storage after your data store is created.
	IotSiteWiseMultiLayerStorage interface{} `json:"iotSiteWiseMultiLayerStorage" yaml:"iotSiteWiseMultiLayerStorage"`
	// Use this to store data store data in an S3 bucket managed by the AWS IoT Analytics service.
	//
	// The choice of service-managed or customer-managed S3 storage cannot be changed after creation of the data store.
	ServiceManagedS3 interface{} `json:"serviceManagedS3" yaml:"serviceManagedS3"`
}

Where data store data is stored.

TODO: EXAMPLE

type CfnDatastore_FileFormatConfigurationProperty

type CfnDatastore_FileFormatConfigurationProperty struct {
	// Contains the configuration information of the JSON format.
	JsonConfiguration interface{} `json:"jsonConfiguration" yaml:"jsonConfiguration"`
	// Contains the configuration information of the Parquet format.
	ParquetConfiguration interface{} `json:"parquetConfiguration" yaml:"parquetConfiguration"`
}

Contains the configuration information of file formats. AWS IoT Analytics data stores support JSON and [Parquet](https://docs.aws.amazon.com/https://parquet.apache.org/) .

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.

TODO: EXAMPLE

type CfnDatastore_IotSiteWiseMultiLayerStorageProperty

type CfnDatastore_IotSiteWiseMultiLayerStorageProperty struct {
	// Stores data used by AWS IoT SiteWise in an Amazon S3 bucket that you manage.
	CustomerManagedS3Storage interface{} `json:"customerManagedS3Storage" yaml:"customerManagedS3Storage"`
}

Stores data used by AWS IoT SiteWise in an Amazon S3 bucket that you manage.

You can't change the choice of Amazon S3 storage after your data store is created.

TODO: EXAMPLE

type CfnDatastore_ParquetConfigurationProperty

type CfnDatastore_ParquetConfigurationProperty struct {
	// Information needed to define a schema.
	SchemaDefinition interface{} `json:"schemaDefinition" yaml:"schemaDefinition"`
}

Contains the configuration information of the Parquet format.

TODO: EXAMPLE

type CfnDatastore_PartitionProperty

type CfnDatastore_PartitionProperty struct {
	// The name of the attribute that defines a partition dimension.
	AttributeName *string `json:"attributeName" yaml:"attributeName"`
}

A single dimension to partition a data store.

The dimension must be an `AttributePartition` or a `TimestampPartition` .

TODO: EXAMPLE

type CfnDatastore_RetentionPeriodProperty

type CfnDatastore_RetentionPeriodProperty struct {
	// The number of days that message data is kept.
	//
	// The `unlimited` parameter must be false.
	NumberOfDays *float64 `json:"numberOfDays" yaml:"numberOfDays"`
	// If true, message data is kept indefinitely.
	Unlimited interface{} `json:"unlimited" yaml:"unlimited"`
}

How long, in days, message data is kept.

TODO: EXAMPLE

type CfnDatastore_SchemaDefinitionProperty

type CfnDatastore_SchemaDefinitionProperty struct {
	// Specifies one or more columns that store your data.
	//
	// Each schema can have up to 100 columns. Each column can have up to 100 nested types.
	Columns interface{} `json:"columns" yaml:"columns"`
}

Information needed to define a schema.

TODO: EXAMPLE

type CfnDatastore_TimestampPartitionProperty

type CfnDatastore_TimestampPartitionProperty struct {
	// The attribute name of the partition defined by a timestamp.
	AttributeName *string `json:"attributeName" yaml:"attributeName"`
	// The timestamp format of a partition defined by a timestamp.
	//
	// The default format is seconds since epoch (January 1, 1970 at midnight UTC time).
	TimestampFormat *string `json:"timestampFormat" yaml:"timestampFormat"`
}

A partition dimension defined by a timestamp attribute.

TODO: EXAMPLE

type CfnPipeline

type CfnPipeline interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrId() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() awscdk.ConstructNode
	PipelineActivities() interface{}
	SetPipelineActivities(val interface{})
	PipelineName() *string
	SetPipelineName(val *string)
	Ref() *string
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::IoTAnalytics::Pipeline`.

The AWS::IoTAnalytics::Pipeline resource consumes messages from one or more channels 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. For more information, see [How to Use AWS IoT Analytics](https://docs.aws.amazon.com/iotanalytics/latest/userguide/welcome.html#aws-iot-analytics-how) in the *AWS IoT Analytics User Guide* .

TODO: EXAMPLE

func NewCfnPipeline

func NewCfnPipeline(scope awscdk.Construct, id *string, props *CfnPipelineProps) CfnPipeline

Create a new `AWS::IoTAnalytics::Pipeline`.

type CfnPipelineProps

type CfnPipelineProps struct {
	// 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": { ... } }, ... ]`
	PipelineActivities interface{} `json:"pipelineActivities" yaml:"pipelineActivities"`
	// The name of the pipeline.
	PipelineName *string `json:"pipelineName" yaml:"pipelineName"`
	// Metadata which can be used to manage the pipeline.
	//
	// For more information, see [Tag](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html) .
	Tags *[]*awscdk.CfnTag `json:"tags" yaml:"tags"`
}

Properties for defining a `CfnPipeline`.

TODO: EXAMPLE

type CfnPipeline_ActivityProperty

type CfnPipeline_ActivityProperty struct {
	// Adds other attributes based on existing attributes in the message.
	AddAttributes interface{} `json:"addAttributes" yaml:"addAttributes"`
	// Determines the source of the messages to be processed.
	Channel interface{} `json:"channel" yaml:"channel"`
	// Specifies where to store the processed message data.
	Datastore interface{} `json:"datastore" yaml:"datastore"`
	// Adds data from the AWS IoT device registry to your message.
	DeviceRegistryEnrich interface{} `json:"deviceRegistryEnrich" yaml:"deviceRegistryEnrich"`
	// Adds information from the AWS IoT Device Shadows service to a message.
	DeviceShadowEnrich interface{} `json:"deviceShadowEnrich" yaml:"deviceShadowEnrich"`
	// Filters a message based on its attributes.
	Filter interface{} `json:"filter" yaml:"filter"`
	// Runs a Lambda function to modify the message.
	Lambda interface{} `json:"lambda" yaml:"lambda"`
	// Computes an arithmetic expression using the message's attributes and adds it to the message.
	Math interface{} `json:"math" yaml:"math"`
	// Removes attributes from a message.
	RemoveAttributes interface{} `json:"removeAttributes" yaml:"removeAttributes"`
	// Creates a new message using only the specified attributes from the original message.
	SelectAttributes interface{} `json:"selectAttributes" yaml:"selectAttributes"`
}

An activity that performs a transformation on a message.

TODO: EXAMPLE

type CfnPipeline_AddAttributesProperty

type CfnPipeline_AddAttributesProperty struct {
	// A list of 1-50 "AttributeNameMapping" objects that map an existing attribute to a new attribute.
	//
	// > The existing attributes remain in the message, so if you want to remove the originals, use "RemoveAttributeActivity".
	Attributes interface{} `json:"attributes" yaml:"attributes"`
	// The name of the 'addAttributes' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

type CfnPipeline_ChannelProperty

type CfnPipeline_ChannelProperty struct {
	// The name of the channel from which the messages are processed.
	ChannelName *string `json:"channelName" yaml:"channelName"`
	// The name of the 'channel' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

Determines the source of the messages to be processed.

TODO: EXAMPLE

type CfnPipeline_DatastoreProperty

type CfnPipeline_DatastoreProperty struct {
	// The name of the data store where processed messages are stored.
	DatastoreName *string `json:"datastoreName" yaml:"datastoreName"`
	// The name of the datastore activity.
	Name *string `json:"name" yaml:"name"`
}

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

TODO: EXAMPLE

type CfnPipeline_DeviceRegistryEnrichProperty

type CfnPipeline_DeviceRegistryEnrichProperty struct {
	// The name of the attribute that is added to the message.
	Attribute *string `json:"attribute" yaml:"attribute"`
	// The name of the 'deviceRegistryEnrich' activity.
	Name *string `json:"name" yaml:"name"`
	// The ARN of the role that allows access to the device's registry information.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
	// The name of the IoT device whose registry information is added to the message.
	ThingName *string `json:"thingName" yaml:"thingName"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

type CfnPipeline_DeviceShadowEnrichProperty

type CfnPipeline_DeviceShadowEnrichProperty struct {
	// The name of the attribute that is added to the message.
	Attribute *string `json:"attribute" yaml:"attribute"`
	// The name of the 'deviceShadowEnrich' activity.
	Name *string `json:"name" yaml:"name"`
	// The ARN of the role that allows access to the device's shadow.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
	// The name of the IoT device whose shadow information is added to the message.
	ThingName *string `json:"thingName" yaml:"thingName"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

type CfnPipeline_FilterProperty

type CfnPipeline_FilterProperty struct {
	// An expression that looks like an SQL WHERE clause that must return a Boolean value.
	Filter *string `json:"filter" yaml:"filter"`
	// The name of the 'filter' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

An activity that filters a message based on its attributes.

TODO: EXAMPLE

type CfnPipeline_LambdaProperty

type CfnPipeline_LambdaProperty struct {
	// The number of messages passed to the Lambda function for processing.
	//
	// The AWS Lambda function must be able to process all of these messages within five minutes, which is the maximum timeout duration for Lambda functions.
	BatchSize *float64 `json:"batchSize" yaml:"batchSize"`
	// The name of the Lambda function that is run on the message.
	LambdaName *string `json:"lambdaName" yaml:"lambdaName"`
	// The name of the 'lambda' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

type CfnPipeline_MathProperty

type CfnPipeline_MathProperty struct {
	// The name of the attribute that contains the result of the math operation.
	Attribute *string `json:"attribute" yaml:"attribute"`
	// An expression that uses one or more existing attributes and must return an integer value.
	Math *string `json:"math" yaml:"math"`
	// The name of the 'math' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

type CfnPipeline_RemoveAttributesProperty

type CfnPipeline_RemoveAttributesProperty struct {
	// A list of 1-50 attributes to remove from the message.
	Attributes *[]*string `json:"attributes" yaml:"attributes"`
	// The name of the 'removeAttributes' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

An activity that removes attributes from a message.

TODO: EXAMPLE

type CfnPipeline_SelectAttributesProperty

type CfnPipeline_SelectAttributesProperty struct {
	// A list of the attributes to select from the message.
	Attributes *[]*string `json:"attributes" yaml:"attributes"`
	// The name of the 'selectAttributes' activity.
	Name *string `json:"name" yaml:"name"`
	// The next activity in the pipeline.
	Next *string `json:"next" yaml:"next"`
}

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

TODO: EXAMPLE

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL