Values_0.ActionSourceDescribes the actions associated with a rule.
type nonrec t = {dynamoDB : DynamoDBAction.t option;Write to a DynamoDB table.
*)dynamoDBv2 : DynamoDBv2Action.t option;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.
*)lambda : LambdaAction.t option;Invoke a Lambda function.
*)sns : SnsAction.t option;Publish to an Amazon SNS topic.
*)sqs : SqsAction.t option;Publish to an Amazon SQS queue.
*)kinesis : KinesisAction.t option;Write data to an Amazon Kinesis stream.
*)republish : RepublishAction.t option;Publish to another MQTT topic.
*)s3 : S3Action.t option;Write to an Amazon S3 bucket.
*)firehose : FirehoseAction.t option;Write to an Amazon Kinesis Firehose stream.
*)cloudwatchMetric : CloudwatchMetricAction.t option;Capture a CloudWatch metric.
*)cloudwatchAlarm : CloudwatchAlarmAction.t option;Change the state of a CloudWatch alarm.
*)cloudwatchLogs : CloudwatchLogsAction.t option;Send data to CloudWatch Logs.
*)elasticsearch : ElasticsearchAction.t option;Write data to an Amazon OpenSearch Service domain. The Elasticsearch action can only be used by existing rule actions. To create a new rule action or to update an existing rule action, use the OpenSearch rule action instead. For more information, see OpenSearchAction.
*)salesforce : SalesforceAction.t option;Send a message to a Salesforce IoT Cloud Input Stream.
*)iotAnalytics : IotAnalyticsAction.t option;Sends message data to an IoT Analytics channel.
*)iotEvents : IotEventsAction.t option;Sends an input to an IoT Events detector.
*)iotSiteWise : IotSiteWiseAction.t option;Sends data from the MQTT message that triggered the rule to IoT SiteWise asset properties.
*)stepFunctions : StepFunctionsAction.t option;Starts execution of a Step Functions state machine.
*)timestream : TimestreamAction.t option;The Timestream rule action writes attributes (measures) from an MQTT message into an Amazon Timestream table. For more information, see the Timestream topic rule action documentation.
*)http : HttpAction.t option;Send data to an HTTPS endpoint.
*)kafka : KafkaAction.t option;Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.
*)openSearch : OpenSearchAction.t option;Write data to an Amazon OpenSearch Service domain.
*)location : LocationAction.t option;The Amazon Location Service rule action sends device location updates from an MQTT message to an Amazon Location tracker resource.
*)}val make :
?dynamoDB:??? ->
?dynamoDBv2:??? ->
?lambda:??? ->
?sns:??? ->
?sqs:??? ->
?kinesis:??? ->
?republish:??? ->
?s3:??? ->
?firehose:??? ->
?cloudwatchMetric:??? ->
?cloudwatchAlarm:??? ->
?cloudwatchLogs:??? ->
?elasticsearch:??? ->
?salesforce:??? ->
?iotAnalytics:??? ->
?iotEvents:??? ->
?iotSiteWise:??? ->
?stepFunctions:??? ->
?timestream:??? ->
?http:??? ->
?kafka:??? ->
?openSearch:??? ->
?location:??? ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Structure of
(string
* [> `Boolean of UseBase64.t
| `Enum of string
| `Integer of Qos.t
| `List of
[> `Structure of
(string
* [> `List of
[> `Structure of
(string
* [> `String of AssetPropertyQuality.t
| `Structure of
(string
* [> `String of
AssetPropertyStringValue.t ])
list ])
list ]
list
| `String of AssetPropertyEntryId.t ])
list ]
list
| `Map of
([> `String of String_.t ] * [> `String of String_.t ])
list
| `String of TableName.t
| `Structure of
(string
* [> `Boolean of BatchAcrossTopics.t
| `Integer of MaxBatchOpenMs.t
| `List of
[> `Structure of
(string * [> `String of UserPropertyKey.t ]) list ]
list
| `String of TableName.t
| `Structure of
(string * [> `String of SigningRegion.t ]) list ])
list ])
list ])
list ]