interface ActionProperty
| Language | Type name |
|---|---|
.NET | Amazon.CDK.Mixins.Preview.AWS.IoT.Mixins.CfnTopicRulePropsMixin.ActionProperty |
Go | github.com/aws/aws-cdk-go/awscdkmixinspreview/v2/awsiot/mixins#CfnTopicRulePropsMixin_ActionProperty |
Java | software.amazon.awscdk.mixins.preview.services.iot.mixins.CfnTopicRulePropsMixin.ActionProperty |
Python | aws_cdk.mixins_preview.aws_iot.mixins.CfnTopicRulePropsMixin.ActionProperty |
TypeScript | @aws-cdk/mixins-preview » aws_iot » mixins » CfnTopicRulePropsMixin » ActionProperty |
Describes the actions associated with a rule.
Example
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import { mixins as iot_mixins } from '@aws-cdk/mixins-preview/aws-iot';
const actionProperty: iot_mixins.CfnTopicRulePropsMixin.ActionProperty = {
cloudwatchAlarm: {
alarmName: 'alarmName',
roleArn: 'roleArn',
stateReason: 'stateReason',
stateValue: 'stateValue',
},
cloudwatchLogs: {
batchMode: false,
logGroupName: 'logGroupName',
roleArn: 'roleArn',
},
cloudwatchMetric: {
metricName: 'metricName',
metricNamespace: 'metricNamespace',
metricTimestamp: 'metricTimestamp',
metricUnit: 'metricUnit',
metricValue: 'metricValue',
roleArn: 'roleArn',
},
dynamoDb: {
hashKeyField: 'hashKeyField',
hashKeyType: 'hashKeyType',
hashKeyValue: 'hashKeyValue',
payloadField: 'payloadField',
rangeKeyField: 'rangeKeyField',
rangeKeyType: 'rangeKeyType',
rangeKeyValue: 'rangeKeyValue',
roleArn: 'roleArn',
tableName: 'tableName',
},
dynamoDBv2: {
putItem: {
tableName: 'tableName',
},
roleArn: 'roleArn',
},
elasticsearch: {
endpoint: 'endpoint',
id: 'id',
index: 'index',
roleArn: 'roleArn',
type: 'type',
},
firehose: {
batchMode: false,
deliveryStreamName: 'deliveryStreamName',
roleArn: 'roleArn',
separator: 'separator',
},
http: {
auth: {
sigv4: {
roleArn: 'roleArn',
serviceName: 'serviceName',
signingRegion: 'signingRegion',
},
},
confirmationUrl: 'confirmationUrl',
headers: [{
key: 'key',
value: 'value',
}],
url: 'url',
},
iotAnalytics: {
batchMode: false,
channelName: 'channelName',
roleArn: 'roleArn',
},
iotEvents: {
batchMode: false,
inputName: 'inputName',
messageId: 'messageId',
roleArn: 'roleArn',
},
iotSiteWise: {
putAssetPropertyValueEntries: [{
assetId: 'assetId',
entryId: 'entryId',
propertyAlias: 'propertyAlias',
propertyId: 'propertyId',
propertyValues: [{
quality: 'quality',
timestamp: {
offsetInNanos: 'offsetInNanos',
timeInSeconds: 'timeInSeconds',
},
value: {
booleanValue: 'booleanValue',
doubleValue: 'doubleValue',
integerValue: 'integerValue',
stringValue: 'stringValue',
},
}],
}],
roleArn: 'roleArn',
},
kafka: {
clientProperties: {
clientPropertiesKey: 'clientProperties',
},
destinationArn: 'destinationArn',
headers: [{
key: 'key',
value: 'value',
}],
key: 'key',
partition: 'partition',
topic: 'topic',
},
kinesis: {
partitionKey: 'partitionKey',
roleArn: 'roleArn',
streamName: 'streamName',
},
lambda: {
functionArn: 'functionArn',
},
location: {
deviceId: 'deviceId',
latitude: 'latitude',
longitude: 'longitude',
roleArn: 'roleArn',
timestamp: {
unit: 'unit',
value: 'value',
},
trackerName: 'trackerName',
},
openSearch: {
endpoint: 'endpoint',
id: 'id',
index: 'index',
roleArn: 'roleArn',
type: 'type',
},
republish: {
headers: {
contentType: 'contentType',
correlationData: 'correlationData',
messageExpiry: 'messageExpiry',
payloadFormatIndicator: 'payloadFormatIndicator',
responseTopic: 'responseTopic',
userProperties: [{
key: 'key',
value: 'value',
}],
},
qos: 123,
roleArn: 'roleArn',
topic: 'topic',
},
s3: {
bucketName: 'bucketName',
cannedAcl: 'cannedAcl',
key: 'key',
roleArn: 'roleArn',
},
sns: {
messageFormat: 'messageFormat',
roleArn: 'roleArn',
targetArn: 'targetArn',
},
sqs: {
queueUrl: 'queueUrl',
roleArn: 'roleArn',
useBase64: false,
},
stepFunctions: {
executionNamePrefix: 'executionNamePrefix',
roleArn: 'roleArn',
stateMachineName: 'stateMachineName',
},
timestream: {
databaseName: 'databaseName',
dimensions: [{
name: 'name',
value: 'value',
}],
roleArn: 'roleArn',
tableName: 'tableName',
timestamp: {
unit: 'unit',
value: 'value',
},
},
};
Properties
| Name | Type | Description |
|---|---|---|
| cloudwatch | IResolvable | Cloudwatch | Change the state of a CloudWatch alarm. |
| cloudwatch | IResolvable | Cloudwatch | Sends data to CloudWatch. |
| cloudwatch | IResolvable | Cloudwatch | Capture a CloudWatch metric. |
| dynamo | IResolvable | Dynamo | Write to a DynamoDB table. |
| dynamo | IResolvable | Dynamo | Write to a DynamoDB table. |
| elasticsearch? | IResolvable | Elasticsearch | Write data to an Amazon OpenSearch Service domain. |
| firehose? | IResolvable | Firehose | Write to an Amazon Kinesis Firehose stream. |
| http? | IResolvable | Http | Send data to an HTTPS endpoint. |
| iot | IResolvable | Iot | Sends message data to an AWS IoT Analytics channel. |
| iot | IResolvable | Iot | Sends an input to an AWS IoT Events detector. |
| iot | IResolvable | Iot | Sends data from the MQTT message that triggered the rule to AWS IoT SiteWise asset properties. |
| kafka? | IResolvable | Kafka | Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster. |
| kinesis? | IResolvable | Kinesis | Write data to an Amazon Kinesis stream. |
| lambda? | IResolvable | Lambda | Invoke a Lambda function. |
| location? | IResolvable | Location | Sends device location data to Amazon Location Service . |
| open | IResolvable | Open | Write data to an Amazon OpenSearch Service domain. |
| republish? | IResolvable | Republish | Publish to another MQTT topic. |
| s3? | IResolvable | S3 | Write to an Amazon S3 bucket. |
| sns? | IResolvable | Sns | Publish to an Amazon SNS topic. |
| sqs? | IResolvable | Sqs | Publish to an Amazon SQS queue. |
| step | IResolvable | Step | Starts execution of a Step Functions state machine. |
| timestream? | IResolvable | Timestream | Writes attributes from an MQTT message. |
cloudwatchAlarm?
Type:
IResolvable | Cloudwatch
(optional)
Change the state of a CloudWatch alarm.
cloudwatchLogs?
Type:
IResolvable | Cloudwatch
(optional)
Sends data to CloudWatch.
cloudwatchMetric?
Type:
IResolvable | Cloudwatch
(optional)
Capture a CloudWatch metric.
dynamoDBv2?
Type:
IResolvable | Dynamo
(optional)
Write to a DynamoDB table.
This is a new version of the DynamoDB action. It allows you to write each attribute in an MQTT message payload into a separate DynamoDB column.
dynamoDb?
Type:
IResolvable | Dynamo
(optional)
Write to a DynamoDB table.
elasticsearch?
Type:
IResolvable | Elasticsearch
(optional)
Write data to an Amazon OpenSearch Service domain.
The
Elasticsearchaction can only be used by existing rule actions. To create a new rule action or to update an existing rule action, use theOpenSearchrule action instead. For more information, see OpenSearchAction .
firehose?
Type:
IResolvable | Firehose
(optional)
Write to an Amazon Kinesis Firehose stream.
http?
Type:
IResolvable | Http
(optional)
Send data to an HTTPS endpoint.
iotAnalytics?
Type:
IResolvable | Iot
(optional)
Sends message data to an AWS IoT Analytics channel.
iotEvents?
Type:
IResolvable | Iot
(optional)
Sends an input to an AWS IoT Events detector.
iotSiteWise?
Type:
IResolvable | Iot
(optional)
Sends data from the MQTT message that triggered the rule to AWS IoT SiteWise asset properties.
kafka?
Type:
IResolvable | Kafka
(optional)
Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.
kinesis?
Type:
IResolvable | Kinesis
(optional)
Write data to an Amazon Kinesis stream.
lambda?
Type:
IResolvable | Lambda
(optional)
Invoke a Lambda function.
location?
Type:
IResolvable | Location
(optional)
Sends device location data to Amazon Location Service .
openSearch?
Type:
IResolvable | Open
(optional)
Write data to an Amazon OpenSearch Service domain.
republish?
Type:
IResolvable | Republish
(optional)
Publish to another MQTT topic.
s3?
Type:
IResolvable | S3
(optional)
Write to an Amazon S3 bucket.
sns?
Type:
IResolvable | Sns
(optional)
Publish to an Amazon SNS topic.
sqs?
Type:
IResolvable | Sqs
(optional)
Publish to an Amazon SQS queue.
stepFunctions?
Type:
IResolvable | Step
(optional)
Starts execution of a Step Functions state machine.
timestream?
Type:
IResolvable | Timestream
(optional)
Writes attributes from an MQTT message.

.NET
Go
Java
Python
TypeScript