我有一个Flask微服务,需要将一个表单发布保存到AWS DynamoDB(通过boto3)和Elastic Search DB(在EC2上运行)。我首先考虑编写一个Python AsyncIO服务器来实现代理/观察者模式,但它看起来像是在重新发明Rabbitmq / Redis PubSub已经完成的工作。但是,我找不到直接的文档(两个文档站点),因此,我正在寻找这种常见模式的示例。任何指点都会有帮助,感谢您的帮助。
谢谢,
看起来您已经在使用AWS,所以为什么不使用SNS。您可以创建具有两个订阅者(DynamoDB和ElasticSearch)的form_post_topic
,然后将消息发送到该主题。