当前位置: 首页 > 知识库问答 >
问题:

AWS SQS接收来自AWS外部的消息

廖鸿达
2023-03-14

我的公司有一个以JSON格式发送实时消息的消息传递系统,它不是建立在AWS上的,也不会与AWS有任何VPN连接。

我们的团队正在尝试使用AWS SQS接收这些消息,然后DynamoDB将JSON消息处理到TSV,然后加载到RDS中。

但是,根据FAQ,SQS只能从AWS内部接收消息。https://aws.amazon.com/sqs/faqs/

我在这里的问题是:

  1. 我的想法正确吗?
  2. 如果正确,您能否分享如何在此EC2实例上构建任何应用程序以实现功能的详细信息(我没有应用程序开发的经验,非常感谢您的见解!)
  3. 在我的用例中,AWS中是否有更容易/更好的选项可以实现接收消息的目标?

共有1个答案

郭修平
2023-03-14

我无法从外部服务写入SQS。我找到了一些部分的解释,但在角色创建上卡住了。

我找到的替代方法是使用AWS服务lambda+API网关写入SQS

本教程非常有用,详细解释了所有步骤:https://startupnextdoor.com/adding-to-sqs-queue-using-aws-lambda-and-a-serverless-api-endpoint/

 类似资料:
  • 我创建了一个SNS主题,通过cli发布来自Cloudformation的所有信息。然而,当我检查队列时,它没有接收任何SNS消息。我通过订阅我的电子邮件来验证SNS是否正常工作,所以问题似乎出在队列和SNS之间的连接上。然而,我没有发现我的语法有任何问题。一、 据我所知,他们严格遵循了亚马逊的文档。 猛击:

  • 在Chrome发布了他们最新的稳定版本(89.0.4389.90),我现在收到这个错误: 硒。常见的例外情况。TimeoutException:消息:超时:从呈现程序接收消息时超时:291.642(会话信息:headless chrome=89.0.4389.90) 我的Python代码是 (我的chromedriver是89.0.4389.23是unic) 有人能帮我修一下吗?

  • 因此,我想知道什么是处理数据库连接问题的最佳方法?每次调用Lambda函数时,我都被迫建立新的连接,还是有办法将这些连接池起来/缓存起来,以便进行更高效的查询? 多谢了。

  • 我有一个包含两台机器(一台主机器和一台工作机器)的集群,在工作节点上有一个pod,它提供SCTP服务。与pod相关的集群服务声明了externalIPs。externalIPs的值是工人机器的公共IP(####.###.208)。当使用helm部署pod和服务时,我可以看到pod和服务都可用,并且外部IP被分配给服务,但netstat命令的结果表明,为sctp服务定义的端口未打开以从外部世界访问,

  • 我在mac上运行Kafka和Flink作为docker容器。 我已经实现了Flink作业,它应该消耗来自Kafka主题的消息。我运行一个向主题发送消息的python生产者。 工作开始时没有问题,但没有收到任何消息。我相信这些消息被发送到了正确的主题,因为我有一个能够使用消息的python消费者。 flink作业(java): Flink作业日志: 生产者作业(python):(在主机上运行-不是d

  • 我有一个简单的SVG在Illustrator中,它的每个部分我想有一个不同的颜色。SVG目前看起来如下所示。 HTML: