Class: AWSCDK::IoTAnalytics::CfnPipeline::ActivityProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
io_t_analytics/cfn_pipeline.rb

Overview

An activity that performs a transformation on a message.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(add_attributes: nil, channel: nil, datastore: nil, device_registry_enrich: nil, device_shadow_enrich: nil, filter: nil, lambda: nil, math: nil, remove_attributes: nil, select_attributes: nil) ⇒ ActivityProperty

Returns a new instance of ActivityProperty.

Parameters:



565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
 
# File 'io_t_analytics/cfn_pipeline.rb', line 565

def initialize(add_attributes: nil, channel: nil, datastore: nil, device_registry_enrich: nil, device_shadow_enrich: nil, filter: nil, lambda: nil, math: nil, remove_attributes: nil, select_attributes: nil)
  @add_attributes = add_attributes.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::AddAttributesProperty.new(**add_attributes.transform_keys(&:to_sym)) : add_attributes
  Jsii::Type.check_type(@add_attributes, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuQWRkQXR0cmlidXRlc1Byb3BlcnR5In1dfX0=")), "addAttributes") unless @add_attributes.nil?
  @channel = channel.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::ChannelProperty.new(**channel.transform_keys(&:to_sym)) : channel
  Jsii::Type.check_type(@channel, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuQ2hhbm5lbFByb3BlcnR5In1dfX0=")), "channel") unless @channel.nil?
  @datastore = datastore.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::DatastoreProperty.new(**datastore.transform_keys(&:to_sym)) : datastore
  Jsii::Type.check_type(@datastore, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuRGF0YXN0b3JlUHJvcGVydHkifV19fQ==")), "datastore") unless @datastore.nil?
  @device_registry_enrich = device_registry_enrich.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::DeviceRegistryEnrichProperty.new(**device_registry_enrich.transform_keys(&:to_sym)) : device_registry_enrich
  Jsii::Type.check_type(@device_registry_enrich, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuRGV2aWNlUmVnaXN0cnlFbnJpY2hQcm9wZXJ0eSJ9XX19")), "deviceRegistryEnrich") unless @device_registry_enrich.nil?
  @device_shadow_enrich = device_shadow_enrich.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::DeviceShadowEnrichProperty.new(**device_shadow_enrich.transform_keys(&:to_sym)) : device_shadow_enrich
  Jsii::Type.check_type(@device_shadow_enrich, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuRGV2aWNlU2hhZG93RW5yaWNoUHJvcGVydHkifV19fQ==")), "deviceShadowEnrich") unless @device_shadow_enrich.nil?
  @filter = filter.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::FilterProperty.new(**filter.transform_keys(&:to_sym)) : filter
  Jsii::Type.check_type(@filter, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuRmlsdGVyUHJvcGVydHkifV19fQ==")), "filter") unless @filter.nil?
  @lambda = lambda.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::LambdaProperty.new(**lambda.transform_keys(&:to_sym)) : lambda
  Jsii::Type.check_type(@lambda, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuTGFtYmRhUHJvcGVydHkifV19fQ==")), "lambda") unless @lambda.nil?
  @math = math.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::MathProperty.new(**math.transform_keys(&:to_sym)) : math
  Jsii::Type.check_type(@math, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuTWF0aFByb3BlcnR5In1dfX0=")), "math") unless @math.nil?
  @remove_attributes = remove_attributes.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::RemoveAttributesProperty.new(**remove_attributes.transform_keys(&:to_sym)) : remove_attributes
  Jsii::Type.check_type(@remove_attributes, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuUmVtb3ZlQXR0cmlidXRlc1Byb3BlcnR5In1dfX0=")), "removeAttributes") unless @remove_attributes.nil?
  @select_attributes = select_attributes.is_a?(Hash) ? ::AWSCDK::IoTAnalytics::CfnPipeline::SelectAttributesProperty.new(**select_attributes.transform_keys(&:to_sym)) : select_attributes
  Jsii::Type.check_type(@select_attributes, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19pb3RhbmFseXRpY3MuQ2ZuUGlwZWxpbmUuU2VsZWN0QXR0cmlidXRlc1Byb3BlcnR5In1dfX0=")), "selectAttributes") unless @select_attributes.nil?
end

Instance Attribute Details

#add_attributes ⇒ AWSCDK::IResolvable, ... (readonly)

Adds other attributes based on existing attributes in the message.

Returns:

See Also:



592
593
594
 
# File 'io_t_analytics/cfn_pipeline.rb', line 592

def add_attributes
  @add_attributes
end

#channel ⇒ AWSCDK::IResolvable, ... (readonly)

Determines the source of the messages to be processed.

Returns:

See Also:



597
598
599
 
# File 'io_t_analytics/cfn_pipeline.rb', line 597

def channel
  @channel
end

#datastore ⇒ AWSCDK::IResolvable, ... (readonly)

Specifies where to store the processed message data.

Returns:

See Also:



602
603
604
 
# File 'io_t_analytics/cfn_pipeline.rb', line 602

def datastore
  @datastore
end

#device_registry_enrich ⇒ AWSCDK::IResolvable, ... (readonly)

Adds data from the AWS IoT device registry to your message.

Returns:

See Also:



607
608
609
 
# File 'io_t_analytics/cfn_pipeline.rb', line 607

def device_registry_enrich
  @device_registry_enrich
end

#device_shadow_enrich ⇒ AWSCDK::IResolvable, ... (readonly)

Adds information from the AWS IoT Device Shadows service to a message.

Returns:

See Also:



612
613
614
 
# File 'io_t_analytics/cfn_pipeline.rb', line 612

def device_shadow_enrich
  @device_shadow_enrich
end

#filter ⇒ AWSCDK::IResolvable, ... (readonly)

Filters a message based on its attributes.

Returns:

See Also:



617
618
619
 
# File 'io_t_analytics/cfn_pipeline.rb', line 617

def filter
  @filter
end

#lambda ⇒ AWSCDK::IResolvable, ... (readonly)

Runs a Lambda function to modify the message.

Returns:

See Also:



622
623
624
 
# File 'io_t_analytics/cfn_pipeline.rb', line 622

def lambda
  @lambda
end

#math ⇒ AWSCDK::IResolvable, ... (readonly)

Computes an arithmetic expression using the message's attributes and adds it to the message.

Returns:

See Also:



627
628
629
 
# File 'io_t_analytics/cfn_pipeline.rb', line 627

def math
  @math
end

#remove_attributes ⇒ AWSCDK::IResolvable, ... (readonly)

Removes attributes from a message.

Returns:

See Also:



632
633
634
 
# File 'io_t_analytics/cfn_pipeline.rb', line 632

def remove_attributes
  @remove_attributes
end

#select_attributes ⇒ AWSCDK::IResolvable, ... (readonly)

Creates a new message using only the specified attributes from the original message.

Returns:

See Also:



637
638
639
 
# File 'io_t_analytics/cfn_pipeline.rb', line 637

def select_attributes
  @select_attributes
end

Class Method Details

.jsii_properties ⇒ Object 



639
640
641
642
643
644
645
646
647
648
649
650
651
652
 
# File 'io_t_analytics/cfn_pipeline.rb', line 639

def self.jsii_properties
  {
    :add_attributes => "addAttributes",
    :channel => "channel",
    :datastore => "datastore",
    :device_registry_enrich => "deviceRegistryEnrich",
    :device_shadow_enrich => "deviceShadowEnrich",
    :filter => "filter",
    :lambda => "lambda",
    :math => "math",
    :remove_attributes => "removeAttributes",
    :select_attributes => "selectAttributes",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
 
# File 'io_t_analytics/cfn_pipeline.rb', line 654

def to_jsii
  result = {}
  result.merge!({
    "addAttributes" => @add_attributes,
    "channel" => @channel,
    "datastore" => @datastore,
    "deviceRegistryEnrich" => @device_registry_enrich,
    "deviceShadowEnrich" => @device_shadow_enrich,
    "filter" => @filter,
    "lambda" => @lambda,
    "math" => @math,
    "removeAttributes" => @remove_attributes,
    "selectAttributes" => @select_attributes,
  })
  result.compact
end