nifi错误:无法建立与amqp代理的连接

nwo49xxi  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(800)

我正在尝试读取以下cap文件中的数据。警报文件夹中的所有内容
http://dd2.weather.gc.ca/alerts/cap/20180205/cwhx/14/
我使用的是来自http://metpx.sourceforge.net. 当我试图从nifi连接到订户时,我得到了以下错误。
无法建立与amqp代理的连接
这是我的cap.conf文件。

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

62lalag41#

整个夏天,代理迁移到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\u 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

它应该有用。要证明这一点可能需要很多小时,因为这一特定的集合(通用警报协议格式的恶劣天气警报)只在需要时生成,而不是连续生成(使用start而不是前台作为后台守护程序运行。)
为了测试东西,从dd\u swob开始可能更容易,这将是一个连续的feed。

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 .*

在这个配置中,您需要在accept行之前添加一个directory选项。应该立即开始下载数据。一旦你知道它的工作原理,切换回你真正想要的数据集。

相关问题