我们正在开发一个监听或使用来自RabbitMQ队列的消息的服务。消息从Apache Nifi分派到消息队列(例如，队列名为“workitem”)。现在，我希望看到一个使用Spring Integration的代码片段，用于侦听和处理从Apache Nifi发送到队列(RabbitMQ)中的消息。 谢谢!
浏览 29提问于2020-04-21得票数 0
回答已采纳
你能帮我在日志中输入RabbitMQ吗？我的应用程序将代码的版本发送到rabbitmq，然后将其存储在弹性堆栈中。在rabbitmq中为app创建了队列名: app_version_queue；类型:经典；持久:真input { id => "重新启动rabbitmq服务器后，所有空间都是空闲的。更新:所有的原因，为什么我要这么做，我想从我想做的链app=>rabbit=>nifi=>
浏览 3提问于2021-02-11得票数 1
回答已采纳
使用celery，是否可以使用RabbitMQ侦听新消息并调度worker来处理它？celery 的很多功能是将其用作具有代理(比如RabbitMQ)的任务生产者，在该代理中执行任务并通过代理交付任务。
浏览 8提问于2018-01-30得票数 1
需要:使用从rabbitMQ读取groovy.lang.MissingMethodException: No signature of method: com.rabbitmq.client.ConnectionFactory.setUri它是从rabbitMQ中读取的。没有连接问题。将python代码放在nifi服务器(1.15.3)机器上，安装python和p
浏览 4提问于2022-03-03得票数 1
我想知道是否有人将Camunda作为数据管道/ETL的调度器和调度器，并且可以分享他的经验。谢谢!
浏览 10提问于2022-05-12得票数 0
回答已采纳
1回答
我目前正在规划一个应用程序的架构，该应用程序从Kafka主题读取数据，并在经过一些转换后将数据转换为RabbitMq。我是Kafka Streams的新手，它们看起来很适合我的任务。但问题是，Kafka服务器托管在另一个供应商的地方，所以我甚至不能安装Cafka Connector to RabbitMq Sink插件。我可以在foreach操作中推送到RabbitMQ，但我不确定流是否可以在没有接收点的情况下工作。
浏览 0提问于2021-06-18得票数 0
我正在尝试使用apache读取一个RabbitMQ代理。重要的是，我可以检索与消息关联的路由密钥，并将有效负载和路由密钥写入文件。
我使用python来读取路由密钥，所以我肯定它是存在的。
浏览 0提问于2018-01-31得票数 1
回答已采纳
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
nifi:restart: on-failure - "8000:8000" - traefik - NIFI_WEB_HTTP_PORT=8000 - nifi_conf:/opt/nifi/conf
- nifi_state:/data/nifi&#x
浏览 96提问于2019-03-25得票数 5
回答已采纳
有没有办法备份和恢复apache Nifi应用程序数据，如nifi-flow-audit.h2.db和控制器服务配置数据？
浏览 35提问于2019-05-15得票数 2
1回答
我正试着和码头工人一起使用nifi，但没有用。我有下面的停靠文件services: image: apache/nifi container_name/nifi:/nifi
image: apache/nifi
hos
浏览 2提问于2020-06-27得票数 1
回答已采纳
MiNiFi版本: 0.4
nifi.web.http.port=nifi.web.https.portProperties Overrides: {}
在MiNiFi windows服务器中，打
浏览 1提问于2019-03-28得票数 2
我已经安装并配置了nifi和nifi-registry。两者都配置为使用OIDC身份验证，在我的OIDC提供程序( Keycloak服务器FWIW)进行身份验证后，我可以成功地访问这两种身份验证。我已经在nifi中配置了nifi-registry URL，但我无法列出nifi-registry中可用的存储桶。实际上，当我查看nifi-registry日志时，我看到了以下内容： 2021-10-21 09:36:27,487 DEBUG [NiFi Re
浏览 40提问于2021-10-21得票数 0
回答已采纳
Nifi v1.15.2默认使用https和身份验证，而对于较早版本的Nifi则不是这样，例如，v1.13.2。我想使用http配置nifi v1.15.2，而不使用身份验证。/work/jettynifi.web.max.header.size=16 KBnifi.web.proxy.host=
nifi</
浏览 33提问于2022-01-07得票数 1
回答已采纳
然后安装Nifi 1.14.0。在房地产方面，我看到的是：为了安全起见，NiFi将在127.0.0.1上显示UI，并且只能通过这个回送接口进行访问。我在防火墙中打开所有端口IP范围: 0.0.0.0/0我想在外部IP上使用UI，比如，我的VM在GCP上。
浏览 10提问于2021-12-11得票数 1
1回答
服务器上有NiFi和NiFi注册表，这是没有连接的，我不能通过本地NiFi instance.But连接到NiFi注册表，我可以通过远程桌面访问NiFi和NiFi注册表。在我的本地开发系统上安装了另一个版本的NiFi和NiFi注册表。有没有办法离线更新(同步)远程NiFi注册表流并将新的更新应用到远程NiFi？ ?
浏览 19提问于2020-11-07得票数 1
我一直在尝试在混合中部署带有动物园管理员和nifi注册中心的nifi集群。我有nifi注册中心和nifi是通过码头部署。在nifi注册中心的文档中，它显示了进入nifi UI并为nifi注册表实例添加一个控制器服务。
是否有一种方法以编程方式为注册表创建控制器服务？(即在构建过程中创建nifi和nifi注册表之间的链接)
浏览 2提问于2021-03-10得票数 0
回答已采纳
1回答
我使用的是Nifi 0.4.1版本。我编写自定义代码来转换CSV到avro格式。我已经创建了类文件(.java文件)并能够生成nar文件。将新创建的nar文件放入lib目录并重新启动nifi服务器。当我打开浏览器并输入localhost:8080/nifi时，浏览器中出现空白页面。此外，命令提示符正在从bin目录中退出。当检查nifi ( status -nifi.bat)的状态时，它表示服务器可能已崩溃或挂起。
感谢任何帮助..
浏览 2提问于2016-03-07得票数 1
我目前正致力于设置NiFi，我注意到作为发行版的一部分，在默认情况下，我们启用了安全特性，这需要用户名和密码来访问UI。对于我的具体用例，我不想要这个。在启动时，我将在哪里以及如何禁用它，以便它的行为类似于较早版本的NiFi？
谢谢!
浏览 35提问于2022-03-22得票数 1
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号