awscdkiotalpha

package module
v2.43.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

README

AWS IoT Construct Library

---

The APIs of higher level constructs in this module are experimental and under active development. They are subject to non-backward compatible changes or removal in any future version. These are not subject to the Semantic Versioning model and breaking changes will be announced in the release notes. This means that while you may use them, you may need to update your source code when upgrading to a newer version of this package.

AWS IoT Core lets you connect billions of IoT devices and route trillions of messages to AWS services without managing infrastructure.

TopicRule

Create a topic rule that give your devices the ability to interact with AWS services. You can create a topic rule with an action that invoke the Lambda action as following:

func := lambda.NewFunction(this, jsii.String("MyFunction"), &functionProps{
	runtime: lambda.runtime_NODEJS_14_X(),
	handler: jsii.String("index.handler"),
	code: lambda.code.fromInline(jsii.String("\n    exports.handler = (event) => {\n      console.log(\"It is test for lambda action of AWS IoT Rule.\", event);\n    };")),
})

iot.NewTopicRule(this, jsii.String("TopicRule"), &topicRuleProps{
	topicRuleName: jsii.String("MyTopicRule"),
	 // optional
	description: jsii.String("invokes the lambda function"),
	 // optional
	sql: iot.iotSql.fromStringAsVer20160323(jsii.String("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'")),
	actions: []iAction{
		actions.NewLambdaFunctionAction(func),
	},
})

Or, you can add an action after constructing the TopicRule instance as following:

var func function


topicRule := iot.NewTopicRule(this, jsii.String("TopicRule"), &topicRuleProps{
	sql: iot.iotSql.fromStringAsVer20160323(jsii.String("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'")),
})
topicRule.addAction(actions.NewLambdaFunctionAction(func))

You can also supply errorAction as following, and the IoT Rule will trigger it if a rule's action is unable to perform:

import logs "github.com/aws/aws-cdk-go/awscdk"


logGroup := logs.NewLogGroup(this, jsii.String("MyLogGroup"))

iot.NewTopicRule(this, jsii.String("TopicRule"), &topicRuleProps{
	sql: iot.iotSql.fromStringAsVer20160323(jsii.String("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'")),
	errorAction: actions.NewCloudWatchLogsAction(logGroup),
})

If you wanna make the topic rule disable, add property enabled: false as following:

iot.NewTopicRule(this, jsii.String("TopicRule"), &topicRuleProps{
	sql: iot.iotSql.fromStringAsVer20160323(jsii.String("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'")),
	enabled: jsii.Boolean(false),
})

See also @aws-cdk/aws-iot-actions for other actions.

Documentation

Overview

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

The CDK Construct Library for AWS::IoT

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewIotSql_Override 

func NewIotSql_Override(i IotSql)

Experimental.

func NewTopicRule_Override 

func NewTopicRule_Override(t TopicRule, scope constructs.Construct, id *string, props *TopicRuleProps)

Experimental.

func TopicRule_IsConstruct 

func TopicRule_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Use this method instead of `instanceof` to properly detect `Construct` instances, even when the construct library is symlinked.

Explanation: in JavaScript, multiple copies of the `constructs` library on disk are seen as independent, completely different libraries. As a consequence, the class `Construct` in each copy of the `constructs` library is seen as a different class, and an instance of one class will not test as `instanceof` the other class. `npm install` will not create installations like this, but users may manually symlink construct libraries together or use a monorepo tool: in those cases, multiple copies of the `constructs` library can be accidentally installed, and `instanceof` will behave unpredictably. It is safest to avoid using `instanceof`, and using this type-testing method instead.

Returns: true if `x` is an object created from a class which extends `Construct`. Experimental.

func TopicRule_IsOwnedResource 

func TopicRule_IsOwnedResource(construct constructs.IConstruct) *bool

Returns true if the construct was created by CDK, and false otherwise. Experimental.

func TopicRule_IsResource 

func TopicRule_IsResource(construct constructs.IConstruct) *bool

Check whether the given construct is a Resource. Experimental.

Types

type ActionConfig 

type ActionConfig struct {
	// The configuration for this action.
	// Experimental.
	Configuration *awsiot.CfnTopicRule_ActionProperty `field:"required" json:"configuration" yaml:"configuration"`
}

Properties for an topic rule action.

Example: 

// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import iot_alpha "github.com/aws/aws-cdk-go/awscdkiotalpha"

actionConfig := &actionConfig{
	configuration: &actionProperty{
		cloudwatchAlarm: &cloudwatchAlarmActionProperty{
			alarmName: jsii.String("alarmName"),
			roleArn: jsii.String("roleArn"),
			stateReason: jsii.String("stateReason"),
			stateValue: jsii.String("stateValue"),
		},
		cloudwatchLogs: &cloudwatchLogsActionProperty{
			logGroupName: jsii.String("logGroupName"),
			roleArn: jsii.String("roleArn"),
		},
		cloudwatchMetric: &cloudwatchMetricActionProperty{
			metricName: jsii.String("metricName"),
			metricNamespace: jsii.String("metricNamespace"),
			metricUnit: jsii.String("metricUnit"),
			metricValue: jsii.String("metricValue"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			metricTimestamp: jsii.String("metricTimestamp"),
		},
		dynamoDb: &dynamoDBActionProperty{
			hashKeyField: jsii.String("hashKeyField"),
			hashKeyValue: jsii.String("hashKeyValue"),
			roleArn: jsii.String("roleArn"),
			tableName: jsii.String("tableName"),

			// the properties below are optional
			hashKeyType: jsii.String("hashKeyType"),
			payloadField: jsii.String("payloadField"),
			rangeKeyField: jsii.String("rangeKeyField"),
			rangeKeyType: jsii.String("rangeKeyType"),
			rangeKeyValue: jsii.String("rangeKeyValue"),
		},
		dynamoDBv2: &dynamoDBv2ActionProperty{
			putItem: &putItemInputProperty{
				tableName: jsii.String("tableName"),
			},
			roleArn: jsii.String("roleArn"),
		},
		elasticsearch: &elasticsearchActionProperty{
			endpoint: jsii.String("endpoint"),
			id: jsii.String("id"),
			index: jsii.String("index"),
			roleArn: jsii.String("roleArn"),
			type: jsii.String("type"),
		},
		firehose: &firehoseActionProperty{
			deliveryStreamName: jsii.String("deliveryStreamName"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			batchMode: jsii.Boolean(false),
			separator: jsii.String("separator"),
		},
		http: &httpActionProperty{
			url: jsii.String("url"),

			// the properties below are optional
			auth: &httpAuthorizationProperty{
				sigv4: &sigV4AuthorizationProperty{
					roleArn: jsii.String("roleArn"),
					serviceName: jsii.String("serviceName"),
					signingRegion: jsii.String("signingRegion"),
				},
			},
			confirmationUrl: jsii.String("confirmationUrl"),
			headers: []interface{}{
				&httpActionHeaderProperty{
					key: jsii.String("key"),
					value: jsii.String("value"),
				},
			},
		},
		iotAnalytics: &iotAnalyticsActionProperty{
			channelName: jsii.String("channelName"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			batchMode: jsii.Boolean(false),
		},
		iotEvents: &iotEventsActionProperty{
			inputName: jsii.String("inputName"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			batchMode: jsii.Boolean(false),
			messageId: jsii.String("messageId"),
		},
		iotSiteWise: &iotSiteWiseActionProperty{
			putAssetPropertyValueEntries: []interface{}{
				&putAssetPropertyValueEntryProperty{
					propertyValues: []interface{}{
						&assetPropertyValueProperty{
							timestamp: &assetPropertyTimestampProperty{
								timeInSeconds: jsii.String("timeInSeconds"),

								// the properties below are optional
								offsetInNanos: jsii.String("offsetInNanos"),
							},
							value: &assetPropertyVariantProperty{
								booleanValue: jsii.String("booleanValue"),
								doubleValue: jsii.String("doubleValue"),
								integerValue: jsii.String("integerValue"),
								stringValue: jsii.String("stringValue"),
							},

							// the properties below are optional
							quality: jsii.String("quality"),
						},
					},

					// the properties below are optional
					assetId: jsii.String("assetId"),
					entryId: jsii.String("entryId"),
					propertyAlias: jsii.String("propertyAlias"),
					propertyId: jsii.String("propertyId"),
				},
			},
			roleArn: jsii.String("roleArn"),
		},
		kafka: &kafkaActionProperty{
			clientProperties: map[string]*string{
				"clientPropertiesKey": jsii.String("clientProperties"),
			},
			destinationArn: jsii.String("destinationArn"),
			topic: jsii.String("topic"),

			// the properties below are optional
			key: jsii.String("key"),
			partition: jsii.String("partition"),
		},
		kinesis: &kinesisActionProperty{
			roleArn: jsii.String("roleArn"),
			streamName: jsii.String("streamName"),

			// the properties below are optional
			partitionKey: jsii.String("partitionKey"),
		},
		lambda: &lambdaActionProperty{
			functionArn: jsii.String("functionArn"),
		},
		openSearch: &openSearchActionProperty{
			endpoint: jsii.String("endpoint"),
			id: jsii.String("id"),
			index: jsii.String("index"),
			roleArn: jsii.String("roleArn"),
			type: jsii.String("type"),
		},
		republish: &republishActionProperty{
			roleArn: jsii.String("roleArn"),
			topic: jsii.String("topic"),

			// the properties below are optional
			qos: jsii.Number(123),
		},
		s3: &s3ActionProperty{
			bucketName: jsii.String("bucketName"),
			key: jsii.String("key"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			cannedAcl: jsii.String("cannedAcl"),
		},
		sns: &snsActionProperty{
			roleArn: jsii.String("roleArn"),
			targetArn: jsii.String("targetArn"),

			// the properties below are optional
			messageFormat: jsii.String("messageFormat"),
		},
		sqs: &sqsActionProperty{
			queueUrl: jsii.String("queueUrl"),
			roleArn: jsii.String("roleArn"),

			// the properties below are optional
			useBase64: jsii.Boolean(false),
		},
		stepFunctions: &stepFunctionsActionProperty{
			roleArn: jsii.String("roleArn"),
			stateMachineName: jsii.String("stateMachineName"),

			// the properties below are optional
			executionNamePrefix: jsii.String("executionNamePrefix"),
		},
		timestream: &timestreamActionProperty{
			databaseName: jsii.String("databaseName"),
			dimensions: []interface{}{
				&timestreamDimensionProperty{
					name: jsii.String("name"),
					value: jsii.String("value"),
				},
			},
			roleArn: jsii.String("roleArn"),
			tableName: jsii.String("tableName"),

			// the properties below are optional
			batchMode: jsii.Boolean(false),
			timestamp: &timestreamTimestampProperty{
				unit: jsii.String("unit"),
				value: jsii.String("value"),
			},
		},
	},
}

Experimental.

type IAction 

type IAction interface {
}

An abstract action for TopicRule. Experimental.

type ITopicRule 

type ITopicRule interface {
	awscdk.IResource
	// The value of the topic rule Amazon Resource Name (ARN), such as arn:aws:iot:us-east-2:123456789012:rule/rule_name.
	// Experimental.
	TopicRuleArn() *string
	// The name topic rule.
	// Experimental.
	TopicRuleName() *string
}

Represents an AWS IoT Rule. Experimental.

func TopicRule_FromTopicRuleArn 

func TopicRule_FromTopicRuleArn(scope constructs.Construct, id *string, topicRuleArn *string) ITopicRule

Import an existing AWS IoT Rule provided an ARN. Experimental.

type IotSql 

type IotSql interface {
	// Returns the IoT SQL configuration.
	// Experimental.
	Bind(scope constructs.Construct) *IotSqlConfig
}

Defines AWS IoT SQL.

Example: 

import sns "github.com/aws/aws-cdk-go/awscdk"

topic := sns.NewTopic(this, jsii.String("MyTopic"))

topicRule := 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.NewSnsTopicAction(topic, &snsTopicActionProps{
			messageFormat: actions.snsActionMessageFormat_JSON,
		}),
	},
})

Experimental.

func IotSql_FromStringAsVer20151008 

func IotSql_FromStringAsVer20151008(sql *string) IotSql

Uses the original SQL version built on 2015-10-08.

Returns: Instance of IotSql. Experimental.

func IotSql_FromStringAsVer20160323 

func IotSql_FromStringAsVer20160323(sql *string) IotSql

Uses the SQL version built on 2016-03-23.

Returns: Instance of IotSql. Experimental.

func IotSql_FromStringAsVerNewestUnstable 

func IotSql_FromStringAsVerNewestUnstable(sql *string) IotSql

Uses the most recent beta SQL version.

If you use this version, it might introduce breaking changes to your rules.

Returns: Instance of IotSql. Experimental.

type IotSqlConfig 

type IotSqlConfig struct {
	// The version of the SQL rules engine to use when evaluating the rule.
	// Experimental.
	AwsIotSqlVersion *string `field:"required" json:"awsIotSqlVersion" yaml:"awsIotSqlVersion"`
	// The SQL statement used to query the topic.
	// Experimental.
	Sql *string `field:"required" json:"sql" yaml:"sql"`
}

The type returned from the `bind()` method in {@link IotSql}.

Example: 

// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import iot_alpha "github.com/aws/aws-cdk-go/awscdkiotalpha"

iotSqlConfig := &iotSqlConfig{
	awsIotSqlVersion: jsii.String("awsIotSqlVersion"),
	sql: jsii.String("sql"),
}

Experimental.

type TopicRule 

type TopicRule interface {
	awscdk.Resource
	ITopicRule
	// The environment this resource belongs to.
	//
	// For resources that are created and managed by the CDK
	// (generally, those created by creating new class instances like Role, Bucket, etc.),
	// this is always the same as the environment of the stack they belong to;
	// however, for imported resources
	// (those obtained from static methods like fromRoleArn, fromBucketName, etc.),
	// that might be different than the stack they were imported into.
	// Experimental.
	Env() *awscdk.ResourceEnvironment
	// The tree node.
	// Experimental.
	Node() constructs.Node
	// Returns a string-encoded token that resolves to the physical name that should be passed to the CloudFormation resource.
	//
	// This value will resolve to one of the following:
	// - a concrete value (e.g. `"my-awesome-bucket"`)
	// - `undefined`, when a name should be generated by CloudFormation
	// - a concrete name generated automatically during synthesis, in
	//    cross-environment scenarios.
	// Experimental.
	PhysicalName() *string
	// The stack in which this resource is defined.
	// Experimental.
	Stack() awscdk.Stack
	// Arn of this topic rule.
	// Experimental.
	TopicRuleArn() *string
	// Name of this topic rule.
	// Experimental.
	TopicRuleName() *string
	// Add a action to the topic rule.
	// Experimental.
	AddAction(action IAction)
	// Apply the given removal policy to this resource.
	//
	// The Removal Policy controls what happens to this resource when it stops
	// being managed by CloudFormation, either because you've removed it from the
	// CDK application or because you've made a change that requires the resource
	// to be replaced.
	//
	// The resource can be deleted (`RemovalPolicy.DESTROY`), or left in your AWS
	// account for data recovery and cleanup later (`RemovalPolicy.RETAIN`).
	// Experimental.
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy)
	// Experimental.
	GeneratePhysicalName() *string
	// Returns an environment-sensitive token that should be used for the resource's "ARN" attribute (e.g. `bucket.bucketArn`).
	//
	// Normally, this token will resolve to `arnAttr`, but if the resource is
	// referenced across environments, `arnComponents` will be used to synthesize
	// a concrete ARN with the resource's physical name. Make sure to reference
	// `this.physicalName` in `arnComponents`.
	// Experimental.
	GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string
	// Returns an environment-sensitive token that should be used for the resource's "name" attribute (e.g. `bucket.bucketName`).
	//
	// Normally, this token will resolve to `nameAttr`, but if the resource is
	// referenced across environments, it will be resolved to `this.physicalName`,
	// which will be a concrete name.
	// Experimental.
	GetResourceNameAttribute(nameAttr *string) *string
	// Returns a string representation of this construct.
	// Experimental.
	ToString() *string
}

Defines an AWS IoT Rule in this stack.

Example: 

import sns "github.com/aws/aws-cdk-go/awscdk"

topic := sns.NewTopic(this, jsii.String("MyTopic"))

topicRule := 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.NewSnsTopicAction(topic, &snsTopicActionProps{
			messageFormat: actions.snsActionMessageFormat_JSON,
		}),
	},
})

Experimental.

func NewTopicRule 

func NewTopicRule(scope constructs.Construct, id *string, props *TopicRuleProps) TopicRule

Experimental.

type TopicRuleProps 

type TopicRuleProps struct {
	// A simplified SQL syntax to filter messages received on an MQTT topic and push the data elsewhere.
	// See: https://docs.aws.amazon.com/iot/latest/developerguide/iot-sql-reference.html
	//
	// Experimental.
	Sql IotSql `field:"required" json:"sql" yaml:"sql"`
	// The actions associated with the topic rule.
	// Experimental.
	Actions *[]IAction `field:"optional" json:"actions" yaml:"actions"`
	// A textual description of the topic rule.
	// Experimental.
	Description *string `field:"optional" json:"description" yaml:"description"`
	// Specifies whether the rule is enabled.
	// Experimental.
	Enabled *bool `field:"optional" json:"enabled" yaml:"enabled"`
	// The action AWS IoT performs when it is unable to perform a rule's action.
	// Experimental.
	ErrorAction IAction `field:"optional" json:"errorAction" yaml:"errorAction"`
	// The name of the topic rule.
	// Experimental.
	TopicRuleName *string `field:"optional" json:"topicRuleName" yaml:"topicRuleName"`
}

Properties for defining an AWS IoT Rule.

Example: 

import sns "github.com/aws/aws-cdk-go/awscdk"

topic := sns.NewTopic(this, jsii.String("MyTopic"))

topicRule := 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.NewSnsTopicAction(topic, &snsTopicActionProps{
			messageFormat: actions.snsActionMessageFormat_JSON,
		}),
	},
})

Experimental.

Source Files

View all Source files

Directories

Path Synopsis
Package jsii contains the functionaility needed for jsii packages to initialize their dependencies and themselves.
 Package jsii contains the functionaility needed for jsii packages to initialize their dependencies and themselves.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.