AMQP - Argo-events：argo-workflow 未触发答案

【问题标题】：AMQP - Argo-events: argo-workflow not triggeredAMQP - Argo-events：argo-workflow 未触发
【发布时间】：2022-05-03 19:43:15
【问题描述】：

我正在尝试运行由事件源触发的 argo 工作流，它监听 RabbitMQ 上发布的消息。我按照这里的确切步骤操作：AMQP-Argo Events

RabbitMQ 控制器 pod 正在运行：

eventbus-controller-7b5bd8b7fd-nggrc      1/1     Running   0          4h24m
events-webhook-6d4dc5b476-fnf6x           1/1     Running   0          4h24m
eventsource-controller-57b6cff5c8-xhfwd   1/1     Running   0          4h24m
rabbitmq-controller-949wp                 1/1     Running   0          178m
sensor-controller-6f5b54468-8ndft         1/1     Running   0          4h24m

当我在交换测试中发布消息时使用：

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.basic_publish(exchange='test',
                      routing_key='hello',
                      body='{"message": "hello"}')

并使用

登录到 pod

kubectl logs pod/<RABBITMQ-CONTROLLER-POD> -n argo-events

我明白了

2021-09-01 22:58:56.437190+00:00 [info] <0.3934.0> accepting AMQP connection <0.3934.0> (127.0.0.1:58396 -> 127.0.0.1:5672)
2021-09-01 22:58:56.442906+00:00 [info] <0.3934.0> connection <0.3934.0> (127.0.0.1:58396 -> 127.0.0.1:5672): user 'guest' authenticated and granted access to vhost '/'

但是，当我使用查看工作流时，我没有看到任何列出的工作流

argo list -n argo-events

所以看起来传感器没有被触发。有人可以建议我可能做错了什么吗？

谢谢！

【问题讨论】：

标签： kubernetes rabbitmq argoproj argo-events

【解决方案1】：

我只能建议（作为仍在从事基本开发实现工作的人）检查模板/示例文件是否设置了适当的凭据和服务帐户 - 当我无法获得资源触发器工作。

【讨论】：