Skip to content

msight_core.nodes.sink_aws_sns_pusher

msight_core.nodes.sink_aws_sns_pusher

AWSSNSPusherSinkNode

Bases: SinkNode

Publish subscribed data to an AWS SNS topic.

Each message is sent as the JSON representation of the data object. SNS message attributes are attached so that SNS subscription filter policies can selectively deliver messages based on:

  • sensor_name – name of the originating sensor (String)
  • device_name – value of MSIGHT_EDGE_DEVICE_NAME (String)
  • capture_timestamp – epoch timestamp of capture (Number), when present
  • creation_timestamp – epoch timestamp of message creation (Number), when present