amazon_kinesis_data_analytics_for_apache_flink_snapshot_manager.py [282:294]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try:
        pub_response = sns.publish(TopicArn=topic_arn, Message=message,
                                   Subject='Kinesis Data Analytics Flink Snapshot Manager Alert')
        if pub_response['ResponseMetadata']['HTTPStatusCode'] == 200:
            message_sent = True
            logger.info(
                'Message published to SNS Topic successfully. Message Id: {0}'.format(pub_response['MessageId']))
    except botocore.exceptions.ClientError as error:
        if error.response['Error']['Code'] == 'ResourceNotFoundException':
            logger.warning('The requested SNS Topic was not found')
        else:
            print('Error Message: {}'.format(error.response['Error']['Message']))
    return message_sent
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



amazon_kinesis_data_analytics_for_apache_flink_snapshot_manager.py [349:361]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try:
        pub_response = sns.publish(TopicArn=topic_arn, Message=message,
                                   Subject='Kinesis Data Analytics Flink Snapshot Manager Alert')
        if pub_response['ResponseMetadata']['HTTPStatusCode'] == 200:
            message_sent = True
            logger.info(
                'Message published to SNS Topic successfully. Message Id: {0}'.format(pub_response['MessageId']))
    except botocore.exceptions.ClientError as error:
        if error.response['Error']['Code'] == 'ResourceNotFoundException':
            logger.warning('The requested SNS Topic was not found')
        else:
            print('Error Message: {}'.format(error.response['Error']['Message']))
    return message_sent
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -