kafka_connect_watcher.aws_sns package

Module contents

Manages SNS notifications to report error and status

class kafka_connect_watcher.aws_sns. SnsChannel ( name , definition ) [source]

Bases: object

property definition : dict

Initial definition

import_jinja2_templates ( ) [source]
Return type :

None

property messages_templates : dict

Messages templates

publish ( subject , message ) [source]

Publish message to SNS

Return type :

None

static render_message_template ( template , cluster_id , connector_name , connector_error ) [source]
Return type :

str

send_error_notification ( cluster , connector ) [source]

Send error notification

property session : Session

Sets the boto3 session up If role_arn is set, we assume_role to get the session, and keep track of expiry. If at execution the expiry passed, re-assume to a new session and get new credentials. Otherwise, use the default Session() set at __init__