def send_sns_notification()

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 = """