Interface CfnPipeline.ActivityProperty
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
CfnPipeline.ActivityProperty.Jsii$Proxy
- Enclosing class:
CfnPipeline
@Stability(Stable)
public static interface CfnPipeline.ActivityProperty
extends software.amazon.jsii.JsiiSerializable
An activity that performs a transformation on a message.
Example:
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import software.amazon.awscdk.services.iotanalytics.*;
ActivityProperty activityProperty = ActivityProperty.builder()
.addAttributes(AddAttributesProperty.builder()
.attributes(Map.of(
"attributesKey", "attributes"))
.name("name")
// the properties below are optional
.next("next")
.build())
.channel(ChannelProperty.builder()
.channelName("channelName")
.name("name")
// the properties below are optional
.next("next")
.build())
.datastore(DatastoreProperty.builder()
.datastoreName("datastoreName")
.name("name")
.build())
.deviceRegistryEnrich(DeviceRegistryEnrichProperty.builder()
.attribute("attribute")
.name("name")
.roleArn("roleArn")
.thingName("thingName")
// the properties below are optional
.next("next")
.build())
.deviceShadowEnrich(DeviceShadowEnrichProperty.builder()
.attribute("attribute")
.name("name")
.roleArn("roleArn")
.thingName("thingName")
// the properties below are optional
.next("next")
.build())
.filter(FilterProperty.builder()
.filter("filter")
.name("name")
// the properties below are optional
.next("next")
.build())
.lambda(LambdaProperty.builder()
.batchSize(123)
.lambdaName("lambdaName")
.name("name")
// the properties below are optional
.next("next")
.build())
.math(MathProperty.builder()
.attribute("attribute")
.math("math")
.name("name")
// the properties below are optional
.next("next")
.build())
.removeAttributes(RemoveAttributesProperty.builder()
.attributes(List.of("attributes"))
.name("name")
// the properties below are optional
.next("next")
.build())
.selectAttributes(SelectAttributesProperty.builder()
.attributes(List.of("attributes"))
.name("name")
// the properties below are optional
.next("next")
.build())
.build();
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic final classA builder forCfnPipeline.ActivityPropertystatic final classAn implementation forCfnPipeline.ActivityProperty -
Method Summary
Modifier and TypeMethodDescriptionbuilder()default ObjectAdds other attributes based on existing attributes in the message.default ObjectDetermines the source of the messages to be processed.default ObjectSpecifies where to store the processed message data.default ObjectAdds data from the AWS IoT device registry to your message.default ObjectAdds information from the AWS IoT Device Shadows service to a message.default ObjectFilters a message based on its attributes.default ObjectRuns a Lambda function to modify the message.default ObjectgetMath()Computes an arithmetic expression using the message's attributes and adds it to the message.default ObjectRemoves attributes from a message.default ObjectCreates a new message using only the specified attributes from the original message.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getAddAttributes
Adds other attributes based on existing attributes in the message.Returns union: either
IResolvableorCfnPipeline.AddAttributesProperty- See Also:
-
getChannel
Determines the source of the messages to be processed.Returns union: either
IResolvableorCfnPipeline.ChannelProperty- See Also:
-
getDatastore
Specifies where to store the processed message data.Returns union: either
IResolvableorCfnPipeline.DatastoreProperty- See Also:
-
getDeviceRegistryEnrich
Adds data from the AWS IoT device registry to your message.Returns union: either
IResolvableorCfnPipeline.DeviceRegistryEnrichProperty- See Also:
-
getDeviceShadowEnrich
Adds information from the AWS IoT Device Shadows service to a message.Returns union: either
IResolvableorCfnPipeline.DeviceShadowEnrichProperty- See Also:
-
getFilter
Filters a message based on its attributes.Returns union: either
IResolvableorCfnPipeline.FilterProperty- See Also:
-
getLambda
Runs a Lambda function to modify the message.Returns union: either
IResolvableorCfnPipeline.LambdaProperty- See Also:
-
getMath
Computes an arithmetic expression using the message's attributes and adds it to the message.Returns union: either
IResolvableorCfnPipeline.MathProperty- See Also:
-
getRemoveAttributes
Removes attributes from a message.Returns union: either
IResolvableorCfnPipeline.RemoveAttributesProperty- See Also:
-
getSelectAttributes
Creates a new message using only the specified attributes from the original message.Returns union: either
IResolvableorCfnPipeline.SelectAttributesProperty- See Also:
-
builder
-