Class FirehosePutRecordAction
(experimental) The action to put the record from an MQTT message to the Kinesis Data Firehose stream.
Inheritance
Implements
Namespace: Amazon.CDK.AWS.IoT.Actions
Assembly: Amazon.CDK.AWS.IoT.Actions.dll
Syntax (csharp)
public class FirehosePutRecordAction : DeputyBase, IAction
Syntax (vb)
Public Class FirehosePutRecordAction
Inherits DeputyBase
Implements IAction
Remarks
Stability: Experimental
ExampleMetadata: infused
Examples
using Amazon.CDK.AWS.KinesisFirehose;
using Amazon.CDK.AWS.KinesisFirehose.Destinations;
var bucket = new Bucket(this, "MyBucket");
var stream = new DeliveryStream(this, "MyStream", new DeliveryStreamProps {
Destinations = new [] { new S3Bucket(bucket) }
});
var topicRule = new TopicRule(this, "TopicRule", new TopicRuleProps {
Sql = IotSql.FromStringAsVer20160323("SELECT * FROM 'device/+/data'"),
Actions = new [] {
new FirehosePutRecordAction(stream, new FirehosePutRecordActionProps {
BatchMode = true,
RecordSeparator = FirehoseRecordSeparator.NEWLINE
}) }
});
Synopsis
Constructors
FirehosePutRecordAction(IDeliveryStream, IFirehosePutRecordActionProps) | |
FirehosePutRecordAction(ByRefValue) | Used by jsii to construct an instance of this class from a Javascript-owned object reference |
FirehosePutRecordAction(DeputyBase.DeputyProps) | Used by jsii to construct an instance of this class from DeputyProps |
Methods
Bind(ITopicRule) | (experimental) Returns the topic rule action specification. |
Constructors
FirehosePutRecordAction(IDeliveryStream, IFirehosePutRecordActionProps)
public FirehosePutRecordAction(IDeliveryStream stream, IFirehosePutRecordActionProps props = null)
Parameters
- stream IDeliveryStream
The Kinesis Data Firehose stream to which to put records.
- props IFirehosePutRecordActionProps
Optional properties to not use default.
Remarks
Stability: Experimental
FirehosePutRecordAction(ByRefValue)
Used by jsii to construct an instance of this class from a Javascript-owned object reference
protected FirehosePutRecordAction(ByRefValue reference)
Parameters
- reference Amazon.JSII.Runtime.Deputy.ByRefValue
The Javascript-owned object reference
FirehosePutRecordAction(DeputyBase.DeputyProps)
Used by jsii to construct an instance of this class from DeputyProps
protected FirehosePutRecordAction(DeputyBase.DeputyProps props)
Parameters
- props Amazon.JSII.Runtime.Deputy.DeputyBase.DeputyProps
The deputy props
Methods
Bind(ITopicRule)
(experimental) Returns the topic rule action specification.
public virtual IActionConfig Bind(ITopicRule rule)
Parameters
- rule ITopicRule
Returns
Remarks
Stability: Experimental