in sample-demo-app/aws_python_sample_application/task_publisher.py [0:0]
def _send_sqs_message(self, message):
try:
self.sqs_client.send_message(
QueueUrl=self.sqs_queue_url,
MessageBody=message
)
print("Sent task to SQS.")
except Exception:
print("Failed to send message onto sqs queue")