hadoop - Nifi 错误 : Failed to establish the connection with AMQP broker

Question

我正在尝试从以下 cap 文件中读取数据。
警报文件夹中的所有内容

http://dd2.weather.gc.ca/alerts/cap/20180205/CWHX/14/

我正在使用来自 http://metpx.sourceforge.net 的 AMQP .当我尝试从 nifi 连接到订阅者时，我收到以下错误。

Failed to establish the connection with AMQP broker

这是我的 cap.conf 文件。

broker amqp://anonymous:anonymous@dd.weather.gc.ca
directory /data
subtopic alerts.cap.#
accept .*
mirror True

Answer 1

整个夏天，代理迁移到 SSL，因此当前 URL 为:amqps://anonymous:anonymous@dd.weather.gc.ca

网页也移至:https://github.com/MetPX/sarracenia

将身份验证信息放入 ~/.config/sarra/credentials.conf 的最佳实践
一行如:amqps://anonymous:anonymous@dd.weather.gc.ca

安装过去一年的版本可能需要很多
更好的体验。它现在带有示例配置，
其中之一是 ddc_cap-xml.conf 与您的数据相同
正在尝试下载。

所以工作是:

blacklab% sr_subscribe add ddc_cap-xml.conf
blacklab% sr_subscribe edit ddc_cap-xml.conf
# Change the directory option to suit your case.
blacklab% sr_subscribe foreground ddc_cap-xml.conf

它应该工作。证明这一点可能需要很多小时，因为这个特定的集合(通用警报协议(protocol)格式的恶劣天气警告)仅在需要时才产生，而不是连续产生。 (使用 start 而不是 foreground 作为后台守护程序运行。)

要进行测试，从 dd_swob 开始可能会更容易，这将是一个连续的提要。

blacklab% sr_subscribe list dd_swob

broker amqp://anonymous@dd.weather.gc.ca
exchange xpublic

#msg_skip_threshold 60
#on_msg ../msg_skip_old.py
subtopic observations.swob-ml.#

accept .*

在此配置中，您需要在接受行之前添加一个目录选项。并且应该立即开始下载数据。一旦你知道它有效，就切换回你真正想要的数据集。