Given a message, publish to this topic.
(self, message)
| 245 | self.capture_response = capture_response |
| 246 | |
| 247 | def _send(self, message): |
| 248 | """ |
| 249 | Given a message, publish to this topic. |
| 250 | """ |
| 251 | message["command"] = "zappa.asynchronous.route_sns_task" |
| 252 | payload = json.dumps(message) |
| 253 | if len(payload) > LAMBDA_ASYNC_PAYLOAD_LIMIT: # pragma: no cover |
| 254 | raise AsyncException("Payload too large for SNS") |
| 255 | self.response = self.client.publish(TargetArn=self.arn, Message=payload) |
| 256 | self.sent = self.response.get("MessageId") |
| 257 | |
| 258 | |
| 259 | ## |
nothing calls this directly
no test coverage detected