Class FirehosePutRecordAction

java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.services.iot.actions.alpha.FirehosePutRecordAction
All Implemented Interfaces:
IAction, software.amazon.jsii.JsiiSerializable

@Generated(value="jsii-pacmak/1.101.0 (build b95fe5d)", date="2024-07-11T03:46:03.864Z") @Stability(Experimental) public class FirehosePutRecordAction extends software.amazon.jsii.JsiiObject implements IAction
(experimental) The action to put the record from an MQTT message to the Kinesis Data Firehose stream.

Example:

 import software.amazon.awscdk.services.kinesisfirehose.alpha.*;
 import software.amazon.awscdk.services.kinesisfirehose.destinations.alpha.*;
 Bucket bucket = new Bucket(this, "MyBucket");
 DeliveryStream stream = DeliveryStream.Builder.create(this, "MyStream")
         .destinations(List.of(new S3Bucket(bucket)))
         .build();
 TopicRule topicRule = TopicRule.Builder.create(this, "TopicRule")
         .sql(IotSql.fromStringAsVer20160323("SELECT * FROM 'device/+/data'"))
         .actions(List.of(
             FirehosePutRecordAction.Builder.create(stream)
                     .batchMode(true)
                     .recordSeparator(FirehoseRecordSeparator.NEWLINE)
                     .build()))
         .build();
 
  • Constructor Details

    • FirehosePutRecordAction

      protected FirehosePutRecordAction(software.amazon.jsii.JsiiObjectRef objRef)
    • FirehosePutRecordAction

      protected FirehosePutRecordAction(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
    • FirehosePutRecordAction

      @Stability(Experimental) public FirehosePutRecordAction(@NotNull IDeliveryStream stream, @Nullable FirehosePutRecordActionProps props)
      Parameters:
      stream - The Kinesis Data Firehose stream to which to put records. This parameter is required.
      props - Optional properties to not use default.
    • FirehosePutRecordAction

      @Stability(Experimental) public FirehosePutRecordAction(@NotNull IDeliveryStream stream)
      Parameters:
      stream - The Kinesis Data Firehose stream to which to put records. This parameter is required.