in amazon_kinesis_data_analytics_for_apache_flink_snapshot_manager.py [0:0]
def send_sns_notification(sns, topic_arn, flink_app_name, snapshot_manager_run_id, snapshot_name, new_snapshot: None,
snapshot_created):
"""
This function sends a notification to Amazon SNS Topic
:param snapshot_name:
:param sns:
:param topic_arn:
:param flink_app_name:
:param snapshot_manager_run_id:
:param new_snapshot:
:param snapshot_created:
:return:
"""
message_sent = False
if snapshot_created:
message = """