我们有一个nifi模板，用于从关系SQL Server DB中提取数据，并将表的每一行作为Marklogic中的文档进行摄取。现在，我们希望在组合中添加DH，并将nifi模板作为注入流的一部分运行，以填充staging DB。将nifi模板作为摄取流的一部分
浏览 24提问于2021-04-07得票数 0
我通过api上传了一个模板，并删除了旧模板，但我如何替换当前正在运行的模板。我知道你可以删除flow.xml，但这需要重新启动。有没有其他方法可以用新的模板替换当前运行的模板。
浏览 0提问于2017-09-19得票数 0
我正在尝试设置一个简单的过程来修改我的CSV文件，并使用Apache Nifi将其摄取到elasticsearch DB。我不想在将文件从一个处理器传递到另一个处理器时，在Stdout上流式传输我的CSV文件。
我已经做了两个流程。我的第一个流程是使用python处理器获取我的CSV文件，使用ExecuteStreamCommand对其进行定制，我在其中运行我的GetFile脚本来读取、修改和保存我
浏览 2提问于2019-08-06得票数 0
我计划使用Apache作为数据摄取用例。源可以是平面文件和Teradata数据库，输出接收器可以是Oracle数据库。我们预测源系统将来可能会发生变化，我注意到Nifi中的处理器可以用来支持这些源。
现在，我的问题是，是否可以在一个Nifi流中从Teradata读取多个表并将数据加载到oracle数据库中的多个表中？我已经为每一张表建立了单独的流程，它似乎运行得很好。
浏览 4提问于2017-03-02得票数 2
回答已采纳
1回答
卡夫卡引发的NiFi工作流瓶颈
、、、、
我正在Apache NiFi中创建一个数据摄取工作流，使用Kafka作为缓冲系统。我设置了一个3节点集群，运行相同的工作流，每个节点有4个核心。我依赖于几个将数据移入和移出不同Kafka主题的实例，这是工作流程中最慢的部分，并且在性能方面非常不一致，因为两个相同的测试可以增加高达100%的持续时间。我们的发布和消费Kafka处理器在所有三个节点上运行，并且我们的K
浏览 16提问于2017-08-15得票数 1
回答已采纳
我正在尝试将CSV文件的数据摄取到MySQL Db中。我的CSV文件有一个名为'MeasurementTime‘值的字段，名为2018-06-27 11:14.50。我的流程将该字段作为字符串，因此PutSQL会产生错误。我使用的模板与此相同，但不使用InferAvro处理器，因为我已经有了预定义的模式。这是网站
如何将日期时间字段作为正确的数据类型而不
浏览 0提问于2018-09-26得票数 2
1回答
据我所知，在使用NiFi构建了一些DB摄取PoCs之后，整个数据流作为流文件运行。并且在任何特定时间，执行控制可以同时在一个或多个处理器上。因此，我真的很困惑如何调试一个复杂的数据流，以防止任何故障。当我们使用生产用例时，它可能会变得比这复杂得多。所以我有几个问题要问。
如何了解数据流的状态。假设10个分叉的流文件中有4个因为数据库池错误而在GenerateTableFetc
浏览 80提问于2018-09-13得票数 2
背景POST /process-groups/{id}/process-groups "revision": {但是，通过测试，我意识到创建的
浏览 4提问于2020-07-23得票数 1
回答已采纳
我们在集群上运行了一个NIFI实例(版本1.7.1)。我正在尝试建立一个简单的工作流，在这里我需要从GCS桶中读取一些文件并将其写入某个目的地。工作流程
作为第一步的一部分，我添加了一个简单的工作流，其中添加了一个ListGCSBucket处理器，并将其附加到LogAttribute处理器中。作为GCPCredentialsControllerService的一部分，我还添加了一个ListG
浏览 0提问于2019-06-20得票数 1
我正在使用NiFi设计一个数据摄取模式。一个进程需要停止释放流程文件，直到下游流程完成处理为止。我试图使用等待和通知，但没有取得任何成功。我希望能在几个处理器之间设置队列大小和背压。类似地，如果有一种实现逻辑的方法:如果当前在多个处理器之间有一个处理，则不要允许流文件进入。
浏览 6提问于2019-12-04得票数 0
回答已采纳
我试图通过使用VSTS管道来自动化发布工作流程，我需要交付的组件基本上是一个库。VSTS管道现在正在构建Visual Studio解决方案，并在工件文件夹中生成二进制文件，但我需要向QA团队发送一封电子邮件，其中包含已作为版本一部分交付的工作项列表。我在marketplace中发现了一个VSTS任务，它使用MD文件生成发行说明：
然而，我需要的是一个基于可定制的HTML模板的任务，并在附件中发送一个ZIP文件与工件文件夹的<
浏览 0提问于2019-10-03得票数 0
我有一个来自.Net Web应用程序的工作的Zapier Webhook调用。但是，即使Zap关闭，我也总是收到“成功”的消息。我认为这是有道理的--“成功”与webhook本身有关，而不是Zap。
在我的.Net网络应用程序中，如果zap被关闭，我想引发一个异常。如何确定Zap是否已关闭？我想这个答案可能在一些Zapier文档中，但我看不到有什么用(我是Zapier的新手)。
浏览 4提问于2019-10-01得票数 0
我最近转向使用IPython笔记本作为我工作流程的一部分。但是，我没有找到将.py文件导入打开的IPython笔记本的单个单元格的方法，以便它们能够编辑、运行并保存。这能办到吗？我在文档中找到了，它告诉我如何将.py文件作为新的笔记本导入，但这与我想要实现的目标相去甚远。
如有任何建议，将不胜感激。
浏览 1提问于2014-01-10得票数 263
回答已采纳
4回答
我们有一个站点需要(作为我们流程的一部分)生成一个文档(例如，Word docx文档)，该文档是从我们的应用程序中的数据与模板文档合并而来的。生成此文档后，用户可以在运行时对其进行编辑。我们知道我们正在寻找一个类似CMS的系统(因为用户将需要能够编辑/创建新的模板)，但我想知道Sharepoint是否可以更好地使用(因为我们不需要传统CMS系统的大量开销
浏览 0提问于2008-12-23得票数 0
回答已采纳
2回答
我的公司每天产生大约600万条记录，我看到hadoop是处理大量数据的一个很好的解决方案。我发现了如何从mysql加载数据，但它正在导出完整的数据库，有没有办法保持我的mysql DB和Hadoop之间的数据同步？
浏览 2提问于2020-03-07得票数 1
是否有可能将作为场景一部分的编辑具体化到铸造中的数据集中？编辑及详细信息：
问题是，我并不是对对象类型的对象进行实际编辑，我不想应用它。我测试了"
浏览 8提问于2022-06-01得票数 1
1回答
但是如果我把它作为SSIS流程的一部分(在Execute process Task中)，它不会产生任何影响。SSIS将它标记为在开始后几毫秒执行，而它应该至少持续10秒。我已经用Execute Process Task解压了7-zip格式的文件，效果很好。
如何将java应用程序作为SSIS过程的一部分运行？编辑:现在我认为我的应用程序正在执行，但ssis不会等待它结束，而是在java应用程序执行<
浏览 1提问于2013-12-12得票数 0
我有一个运行在Google Cloud Dataflow上的Apache光束作业，作为其初始化的一部分，它需要对服务、发布/订阅订阅、GCS blob等运行一些基本的健全性/可用性检查。这是一个旨在无限运行ad的流水线，可以处理数十万条发布/订阅消息。模板是我想要做的事情的正确方法吗？我如何才能真正实现这一点呢？应该(可以吗？)我用maven编译成一个
浏览 5提问于2017-07-27得票数 1
回答已采纳
在红帽软件集合MySQL容器中，我看到可以将MYSQL_DEFAULTS_FILE设置为指示一个完全不同的my.cnf文件的路径。在OpenShift中使用时，我不知道如何在磁盘上获得这样的配置文件，因为它们的S2I脚本已经作为mysql-persistent模板的一部分运行了。如何将这样的文件注入到预先构建的图像中？我能够使用MySQL提供的模板</em
浏览 0提问于2018-05-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
