腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(114)
视频
沙龙
1
回答
如何在
nifi
中设置从进水数据库到hdfs的数据流?
apache-nifi
在
nifi
中,
PutInfluxdb
处理器
可以将数据发送到
Influxdb
.但是没有什么比fetchInfluxdb/ConsumeInfluxdb
处理器
更好的了。那么如何将数据从
Influxdb
推送到hdfs?
浏览 0
提问于2018-06-04
得票数 0
回答已采纳
1
回答
通过Apache的
InfluxDB
处理器
将数据从SQL server发送到
PutInfluxDB
apache-nifi
、
influxdb
我一直试图通过Apache的
InfluxDB
处理器
将数据从server发送到
PutInfluxDB
。我按顺序使用了这些
处理器
: ExecuteSQL、ConvertRecord (从AvroReader到CsvWriter)、
PutInfluxDB
和LogAttribute。 请帮我解决这个问题。
浏览 1
提问于2022-01-14
得票数 0
2
回答
nifi
缺少
标记
值
(
putInfluxDB
InfluxDB
处理器
)
python
、
json
、
apache-kafka
、
apache-nifi
、
influxdb
我是
InfluxDB
的新手,问题在于我必须通过
Nifi
在
InfluxDB
中插入python字典,我尝试了不同的方法,但总是得到相同的错误,告诉我
缺少
标签: ? org.
influxdb
.InfluxDBException: { { "tags":{"t
浏览 87
提问于2019-06-03
得票数 4
1
回答
如何将AVRO方案转换为线协议,以便使用Apache Ni-Fi将数据插入到InfluxBD中
apache-nifi
、
influxdb
我正在使用Apache创建一个数据管道,以便将数据从远程MySQL数据库复制到
InfluxDB
中。我使用QueryDatabaseTable
处理器
从MySQL数据库中提取数据,然后使用UpdateRecord进行一些数据转换,并希望使用
PutInfluxDB
将时间序列插入到Linux中的本地流入实例中来自QueryDatabaseTable
处理器
的数据使用AVRO方案,我需要通过配置哪些是
标记
,哪些是度量值来将其转换为行协议。有什么暗示吗?
浏览 9
提问于2022-01-14
得票数 0
回答已采纳
2
回答
如何在Apache DBCPConnectionPool
NiFi
中实现
NiFi
控制器服务的自动化?
apache
、
apache-nifi
、
hortonworks-data-platform
、
hortonworks-dataflow
、
apache-minifi
我是Apache的新手,我的基本任务是使用Apache将来自多个数据库源的数据摄取到
Nifi
中。
浏览 1
提问于2018-04-03
得票数 2
回答已采纳
1
回答
在
nifi
集群中分发从GetMongo读取的数据
apache-nifi
我有一个集群
nifi
设置,我们在主模式下运行GetMongo
处理器
,这样就不会获取重复的数据。这似乎运行得很好。因此,我的问题是假设GetMongo已经获取了30000条记录,并且它们在队列中:2)如果已将一个
处理器
设置为仅在主节点上运行,流中的所有其他
处理器
是否也在主节点上运行?
浏览 0
提问于2018-11-07
得票数 0
1
回答
多个字段的
NiFi
LookupRecord
apache-nifi
如果一些属性(例如,Emp_number、Manager_id、associate_num)的
值
与查找文件中可用的
值
列表(例如,csv查找文件中的列名ID )匹配,则我要求从源文件中筛选记录。为此,我使用了
NiFi
LookupRecord processor (1.5版)。在查找
处理器
中添加了动态属性"key“,并将记录路径
值
指定为/Emp_number。它工作得很好。但是如果我添加额外的动态属性,比如"key1":/Manager_id和"k
浏览 54
提问于2019-08-22
得票数 3
回答已采纳
1
回答
如何转换Telegraf中的“标签
值
”
influxdb
、
telegraf
如何转换Telegraf中的
标记
值
?而唯一的
处理器
插件(介于输入和输出之间)仅仅是一个"“。
浏览 3
提问于2017-04-13
得票数 2
回答已采纳
1
回答
到
influxDB
的线路协议语句的
nifi
executeScript
apache-nifi
我有一组读取kafka主题的过程,mergeContent & ExecuteScript来读取json字段,并在使用
influxDB
之前映射到
putinfluxDB
。我想创建一个通用脚本,它可以读取json中的任何字段,并相应地将其映射到
influxDB
进程。flowFile = session.get(); Java.type("org.apache.
nifi
.processor.io.Str
浏览 3
提问于2018-07-26
得票数 0
1
回答
InfluxDb
十大违法者
database
、
time-series
、
influxdb
我有一个
InfluxDb
时间序列数据库,我正在存储一个名为api_calls的度量。这个度量有两个相关的度量,call_invoked和call_failed。每个度量还具有一个带有与其关联的供应商id的
标记
。每分钟,我都有一个服务来整理我调用call_invoked (启动API调用时触发)和call_failed (从API调用获得错误消息时触发)并将它们存储到
InfluxDb
中的次数。因此,基本上,每分钟我都会在
InfluxDb
“表”(因为
缺少
一个更好的术语)中得到一条记录(据我理解,每个
标
浏览 1
提问于2017-02-07
得票数 2
1
回答
NiFi
:使用EvaluateXpath
处理器
获取XML中相同
标记
的所有元素
xml
、
xml-parsing
、
apache-nifi
、
hortonworks-dataflow
尝试在
NiFi
中解析下面的xml,并希望解析出所有id,并对每个id进行多个web服务调用。 </store-Ids></soap:Envelope> 有没有一种方法可以解析id
标记
中的所有( 69E32281-0484,3002 AFCD-B4
浏览 0
提问于2018-05-11
得票数 1
回答已采纳
1
回答
NiFi
- ExecuteSQLRecord
处理器
查询中使用的持久化时间戳
值
apache-nifi
我编写了一个查询,它用ExecuteSQLRecord
处理器
命中时列的当前时间戳
标记
数据,并从数据库中获取数据。但我不知道如何捕获属性${now():format("yyyyMMddHHmmss")},这样我就可以使用alter来重命名流文件 基本上,我想存储“在我访问数据库时”的时间戳,我不能在executeSQL
处理器
之前使用更新
处理器
来获取所需的时间戳(为什么使用=>,因为如果先前的执行仍然在executeSQL中,并且所有的流文件都将传递带有时间戳
值
的updateattr
浏览 180
提问于2020-10-28
得票数 0
1
回答
修复格式错误的xml时出现内存错误
python
、
beautifulsoup
、
lxml
、
elementtree
、
large-files
我有一些格式错误的非常大的XML --它
缺少
顶级
标记
,并且有重复的属性。为了解决这个问题,我在格式错误的XML的一个子集上测试了以下解决方案,它可以很好地添加
标记
并使用BeautifulSoup自动删除重复的属性。因为我需要(AFAICT)完整的XML来添加顶级
标记
和删除重复项,所以我不太确定如何修改我的代码来处理这么大的XML。我看到了一些关于使用lxml和迭代的建议,但我不清楚它如何适合我的需求/流程。埃塔:不确定是否有帮助,但重点是清理文件,这样它就可以在
NiFi
的SplitXML
浏览 0
提问于2020-02-20
得票数 0
1
回答
找不到文件异常
apache-nifi
我想获取其中包含xml组件的flowfile,并更新其中一个我在自定义
nifi
处理器
代码中创建的
标记
值
,我的代码如下: flowFile = session.putAttribute(flowFile
浏览 0
提问于2017-10-04
得票数 0
1
回答
Nifi
在码头上向德鲁伊插入数据
docker
、
apache-nifi
、
druid
德鲁伊 你有什么想法吗?如何配置德鲁伊? (非常感谢:)
浏览 0
提问于2018-08-03
得票数 0
1
回答
NiFi
- ConvertCSVtoAVRO -如何捕获失败的记录?
csv
、
avro
、
apache-nifi
拒绝通常是由错误的数据类型引起的-例如,当"string“
值
出现在"long”字段中时。(
NiFi
是否向这些记录添加了一些
标记
等?)两个
处理器
: RouteOnAttribute和RouteOnContent路由整个文件。流的“不兼容”分支是否以某种方式将单个记录
标记
为在将文件拆分为行后可用的"error“属性?我在任何文档中都找不到这个。
浏览 1
提问于2017-01-25
得票数 3
回答已采纳
1
回答
在apache中使用表达式语言进行布尔条件计算是没有意义的
apache-nifi
我需要在此基础上验证流文件属性
值
和路由。最新情况:详细要求:
Nifi
工作流将读取json/csv数据,并一次处理每条记录。目前,我们正在考虑json格式的输入数据。该attr的任何其他
值
都被视为无效的输入数据和到日志
处理器
流的路由。我使用"UpdateAttribute“
处理器
来评估一些逻辑,使用表达式语言查询,并将它们存储在流文件属性下。CURRENCY_CD:isEmpty():not():and(${CURRENCY_CD:length():equals(
浏览 3
提问于2021-01-08
得票数 1
回答已采纳
3
回答
Kylo高水标功能
kylo
我有饲料运行在每五分钟,并使用加载/释放蜂箱水
标记
功能。考虑这样一种情况:作业执行时间超过5分钟,而水
标记
提交没有发生。在这种情况下,Kylo会使用旧的水
标记
启动另一个feed实例,还是等待提交发生?
浏览 2
提问于2017-02-17
得票数 2
回答已采纳
1
回答
从XSLT引发异常
xml
、
xslt
、
railo
据我所知,<xsl:message>
标记
似乎是正确的方法,但到目前为止,它不起作用。</h1><xsl:if>会检测到
缺少
的文档/xpath,并显示将显示的内容,但由于某种原因,<xsl:message>的终止属性将被忽略。转换是在Railo中完成的,因此XSLT
处理器
的使用应该是Java的缺省
值
,但我无法找到关于Railo正在使用的
处理器
的确切信息。
浏览 4
提问于2014-09-03
得票数 3
3
回答
从div id检索xpath内容
html
、
xpath
如何检索文章-字段1中的文本? <link>http://example.org</link> <language>en-us</language> <title>
浏览 2
提问于2012-02-15
得票数 10
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
人工智能:我们终将退出历史舞台
SSM框架搭建
如何利用并发性加速你的 python程序(上)
Cloudflare如何分析每秒上百万的DNS查询
风险投资人眼中的AI初创公司
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券