'Given a message, publish to this topic.'

def _send(self, message):

    message['command'] = 'zappa.async.route_sns_task'
    payload = json.dumps(message).encode('utf-8')
    if (len(payload) > 256000):
        raise AsyncException('Payload    too    large    for    SNS')
    self.response = self.client.publish(TargetArn=self.arn, Message=payload)
    self.sent = self.response.get('MessageId')
