问题标签 [elastic-mq]

我正在使用无服务器，移植两个函数，一个（称为生成器）当前是一个长时间运行的节点进程，另一个（称为检查器）由 cron 触发，因此它们都是 lambdas，由 a 触发的检查器通过接收 SQS 通知来调度和生成器。我也是能够进行本地开发的忠实粉丝，因此添加了 serverless-offline 和 serverless-offline-sqs（由 ElasticMQ 支持）。

移植了生成器，它在本地部署和运行得很好。这是 serverless.yml 中定义的函数：

我可以使用 AWS CLI 通过 ElasticMQ 触发消息（aws account # obfuscated）：

并且消息接收良好，生成器 lambda 触发：

现在我想以编程方式为第二个函数发送 SQS，这几乎是对现有（非 lambda）函数的唯一真正更改。它也部署/启动得很好，但是发送相同消息的 aws-sdk 库函数不起作用。

这是 serverless.yml 中的函数定义。请注意，我注释掉了正常的 cron 计划，因为 serverless-offline 不支持它，并且仅使用 10 分钟的速率进行测试：

这是我作为上述命令行的节点版本添加到函数的其余部分的内容：

这些记录器语句的输出是

在我看来，它确实看起来像代码使用与命令行相同的所有值，但它只是不起作用。希望其他人可以在这里看到明显的东西。

谢谢。

我试图在我的测试环境中模仿 Amazon SQS 系统。我正在使用 ElaticMQ 和 AmazonClientBuilder API，但我在创建队列时一直出现“302 临时移动”错误。请参阅下面的代码

我当前的 ElasticMQ 端口是 64631，我可以看到应用程序正在侦听

谢谢

如何从 ac# 应用程序连接、写入和读取消息？是否有任何 c# 示例？

我尝试运行 AWS SQS 示例并连接到 Docker 中的 ElasticMQ。但无法连接，因为没有 IP:port 参数。SQS 参数包含 AwsRegion 但不包含 IP:Port

我正在使用 ElasticMQ（通过 docker image v1.3.3）并且无法让 DLQ 工作。

这是我的elasticmq.conf：

我正在发送这样的消息（使用 AWS CLI）：

并像这样接收它：

我没有从队列中删除消息，但消息正在被删除并且没有被移动到 DLQ（即重试队列）。我也在尝试使用 Java 代码接收消息并获得相同的结果。

这是为什么？

在我的 sls 项目中，我使用本文设置 sqs 离线使用，如下所示。

1. npm 安装 serverless-offline-sqs 作为开发依赖
2. 在 serverless.ts 插件部分的 serverless-offline 之后包含 serverless-offline-sqs
3. 为队列添加了自定义配置，

4. serverless.ts 资源部分中包含的队列资源：

5. 运行 ElasticMQ 泊坞窗

6. 启动 serverless 离线sls 离线启动

尝试列出队列，不显示 fifo.queue。想知道为什么 autoCreate 没有创建队列。列出队列动作 curl 响应：

想知道为离线模式自动创建队列我缺少什么？离线启动显示“离线：启动离线 SQS：dev/us-east-1”。信息。

版本：