Action (p.awso.0.9.1.doc.awso.iot.Awso_iot.Values

Sourcetype 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:DynamoDBAction.t ->
  ?dynamoDBv2:DynamoDBv2Action.t ->
  ?lambda:LambdaAction.t ->
  ?sns:SnsAction.t ->
  ?sqs:SqsAction.t ->
  ?kinesis:KinesisAction.t ->
  ?republish:RepublishAction.t ->
  ?s3:S3Action.t ->
  ?firehose:FirehoseAction.t ->
  ?cloudwatchMetric:CloudwatchMetricAction.t ->
  ?cloudwatchAlarm:CloudwatchAlarmAction.t ->
  ?cloudwatchLogs:CloudwatchLogsAction.t ->
  ?elasticsearch:ElasticsearchAction.t ->
  ?salesforce:SalesforceAction.t ->
  ?iotAnalytics:IotAnalyticsAction.t ->
  ?iotEvents:IotEventsAction.t ->
  ?iotSiteWise:IotSiteWiseAction.t ->
  ?stepFunctions:StepFunctionsAction.t ->
  ?timestream:TimestreamAction.t ->
  ?http:HttpAction.t ->
  ?kafka:KafkaAction.t ->
  ?openSearch:OpenSearchAction.t ->
  ?location:LocationAction.t ->
  unit ->
  t

Source

val 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 ]

Sourceval to_query : t -> Awso.Client.Query.t

Sourceval of_xml : Awso.Xml.t -> t

Sourceval of_string : string -> t

Sourceval of_json : Yojson.Safe.t -> t

Sourceval to_json : t -> Yojson.Safe.t