问题标签 [amazon-mq]

我创建了 python 脚本，该脚本作为 zip 文件上传到 AWS Lambda 函数中，其中捆绑了 stompy 库。

python 2.7的日志：-

我的代码：-

我不确定为什么我的消息没有出现在我的输出中，而是总是显示“响应：null”。

我需要创建一个 Cloudwatch 事件，它将自动触发我的 Python AWS Lambda 函数。

我按照下面的链接，但没有成功。

https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/RunLambdaSchedule.html

请建议。

云观察事件

Lambda 函数映射

我有一个连接到 AWS MQ 并收集消息的 python 脚本。我所有的连接都完美对齐，执行结果是成功的。但是我的函数执行返回的结果是“null”。更新的错误日志：-

更新了 Python Lambda 函数：-

谁能告诉我如何调试更多以从 MQ 获取消息

MQ URL 消息屏幕截图

MQ 主页

队列下的消息

我已经测试了广泛策略访问的变体，并且达到了同一点——创建了日志组，但没有创建日志流。

关注https://docs.aws.amazon.com/amazon-mq/latest/developer-guide/amazon-mq-configuring-cloudwatch-logs.html ，预期结果是在CloudWatch中获取这些消息，但没有任何消息。

目标是在 CloudWatch 中拥有审计和常规 MQ 日志。有没有人设法在 CloudWatch 中流式传输 MQ 日志？我该如何进一步调试呢？

我正在尝试从 Node JS 向 Amazon MQ 发布消息，但到目前为止我尝试过的所有库似乎都没有工作。

图书馆 1：

代码：

第一个库出错：

图书馆 2：

代码：

第二个库出错：connect error unexpected end of stream

我不确定我还能尝试什么，但我似乎被困在这里，因为错误消息甚至都不冗长，而且网上没有很多关于这个问题的信息。

我在亚马逊论坛上找到的唯一相关文章没有答案： https ://forums.aws.amazon.com/thread.jspa?messageID=831730&tstart=0

我们最近从 Artemis 迁移到 ActiveMQ，现在我们的消息驱动 Bean 面临一些奇怪的行为。

基本上，当某些应用程序失败时，我们会意识到某些消息丢失了。我们进行了一些测试，以确定是否存在 ack 类型、消息持久性等配置问题。但最后，我们得出的结论和我们得到的测试场景是，当我们有一个 MDB 处理消息时，那里没有等待提交的事务，当应用程序死亡时，消息丢失，代理将其从挂起的消息中删除。

但是，如果我们确实有一个带有待提交提交的事务，代理会保留它，并且很快应用程序启动该消息就可以再次处理。

我们将 XA 和资源适配器与 WildFly Swarm 应用程序一起使用。看起来只要一个事务从 MDB 开始并且有一个提交挂起，即使消费者死亡，应用程序也会通知代理保留消息。如果没有事务，一旦代理识别出消费者失去连接，消息就会从队列中删除。

一些信息：

• 即使定义了所需的事务和容器管理，也会发生同样的情况
• 使用 auto 或 dups ack，也会发生同样的情况
• 消息是持久的

我们缺少一些带有 activeMQ 的配置？我们没有找到任何其他属性说明这种 MDB 和事务的行为。什么告诉经纪人他应该持有正在进行交易的消息？有没有办法在使用 MDB 和 XA 失败时保留所有消息？

这是一个带有测试场景的简单 MDB 代码：

insert 方法只是一种持久化实体的方法，并且是事务所需的。

当前技术栈：

A. ActiveMq 与主从配置使用 KahaDb1 与配置 brokerUrl:failover:(tcp://master1:61616,tcp://slave1:61616)?randomize=false

在技​​术堆栈之上，我们希望使用 amazonMq 进行迁移，因为它们都使用相同的协议，我们假设我们这边不需要太多的代码更改，只是配置调整：

B. 使用它的主从节点和单独的 kahaDb2 设置 AmazonMq。

现在我们想自定义端点是这样一种方式，我们可以连续监听两个端点（activemq-master broker 和 amazonmq-master broker），这可能吗？

我知道我们可以设置如下：

故障转移:(ssl://on-premises-broker.example.com:61617,ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617 )?随机化=真

上述情况的问题是我们无法找到一种方法来提及从代理，因为两个集群也都有单独的从节点。如果主节点发生故障转移，我们希望切换到相同架构的从节点（无论是 activemq 还是 amazonmq）我如何通过主动监听两个代理来实现这一点？

我创建了一个简单的消费者，Amazon MQ但看起来我错过了一些东西，因为每当收到消息时，它都应该调用我的 recevieMessage 方法，但它不起作用。
但是我用 apache active MQ 尝试了这个，它工作得很好。

PS：我也尝试过实现MessageListener类覆盖该onMessage()方法但不起作用。我尝试在 receiveMessage方法中使用不同的参数，如Object, Message, ByteMessage....

我的配置：

每次我启动应用程序时都会收到这个： WARN 12740 --- [206:61616@63304] o.a.activemq.ActiveMQSessionExecutor : Received a message on a connection which is not yet started. Have you forgotten to call Connection.start()? Connection: ActiveMQConnection

我知道理论上的区别，例如：

Amazon MQ 提供托管消息代理服务，负责操作 ActiveMQ，包括代理设置、监控、维护和预置底层基础设施以实现高可用性和持久性。当您想要减轻运营开销和相关成本时，您可能需要考虑使用 Amazon MQ。

我要问的是在建立连接、使用活动 MQ 和 Amazon MQ 获取数据方面有什么不同。（在编码方面，主要是在 java 中）我认为没有区别。

我们正在从 ActiveMQ 迁移到AWS 上的amazonMQ。ActiveMQ 和 AmazonMQ 在内部使用 kahaDB 作为数据存储。早些时候，我们在数据中心上使用 activeMQ 时能够看到 kahaDB 日志文件，在使用 amazonMQ 时是否有类似的方法可以在 AWS 上查看 kahadb 日志文件？

1. 尝试启用 cloudwatch 日志，但它包含 amazonMQ 的一般和审计日志。