package awscdkiotactionsalpha import ( _init_ "github.com/aws/aws-cdk-go/awscdkiotactionsalpha/v2/jsii" _jsii_ "github.com/aws/jsii-runtime-go/runtime" "github.com/aws/aws-cdk-go/awscdk/v2/awss3" "github.com/aws/aws-cdk-go/awscdkiotactionsalpha/v2/internal" "github.com/aws/aws-cdk-go/awscdkiotalpha/v2" ) // The action to write the data from an MQTT message to an Amazon S3 bucket. // // Example: // bucket := s3.NewBucket(this, jsii.String("MyBucket")) // // iot.NewTopicRule(this, jsii.String("TopicRule"), &TopicRuleProps{ // Sql: iot.IotSql_FromStringAsVer20160323(jsii.String("SELECT topic(2) as device_id, year, month, day FROM 'device/+/data'")), // Actions: []iAction{ // actions.NewS3PutObjectAction(bucket, &S3PutObjectActionProps{ // Key: jsii.String("${year}/${month}/${day}/${topic(2)}"), // }), // }, // }) // // Experimental. type S3PutObjectAction interface { awscdkiotalpha.IAction } // The jsii proxy struct for S3PutObjectAction type jsiiProxy_S3PutObjectAction struct { internal.Type__awscdkiotalphaIAction } // Experimental. func NewS3PutObjectAction(bucket awss3.IBucket, props *S3PutObjectActionProps) S3PutObjectAction { _init_.Initialize() if err := validateNewS3PutObjectActionParameters(bucket, props); err != nil { panic(err) } j := jsiiProxy_S3PutObjectAction{} _jsii_.Create( "@aws-cdk/aws-iot-actions-alpha.S3PutObjectAction", []interface{}{bucket, props}, &j, ) return &j } // Experimental. func NewS3PutObjectAction_Override(s S3PutObjectAction, bucket awss3.IBucket, props *S3PutObjectActionProps) { _init_.Initialize() _jsii_.Create( "@aws-cdk/aws-iot-actions-alpha.S3PutObjectAction", []interface{}{bucket, props}, s, ) }