我有一组读取kafka主题的过程，mergeContent & ExecuteScript来读取json字段，并在使用influxDB之前映射到putinfluxDB。我有特定的脚本，因为json消息的格式不同，存在不同的字段和标签来执行此操作。我想创建一个通用脚本，它可以读取json中的任何字段，并相应地将其映射到influxDB进程。= null) {
Java.type("or
浏览 3提问于2018-07-26得票数 0
我有influxDB Line记录，通过ConsumeKafka处理器进入NiFi，然后合并成包含10,000个记录的流文件。是否有一种方法将Line转换为PutParquet处理器可消费的东西，或者另一种方式将其转换为Parquet文件？我确实找到了一个定制的处理器，但是关于如何使用这个处理器没有什么信息和例子(我已经找到了)，所以我不确定它是否适合这个用例。或者，我可以使用Spark来完成转换和编写Parquet文件，但是我希望尽一切可能在NiFi中完成所有事情，特别是因为我还没有找
浏览 7提问于2019-12-03得票数 0
回答已采纳
我正在使用行协议和Python编写InfluxDB。下面是创建DB并运行良好的代码。database: " + dbname) print("Database created: " + dbname)的数据行示例如下
interface,path=address,element=l
浏览 4提问于2016-08-25得票数 4
回答已采纳
我一直试图通过Apache的InfluxDB处理器将数据从server发送到PutInfluxDB。我按顺序使用了这些处理器: ExecuteSQL、ConvertRecord (从AvroReader到CsvWriter)、PutInfluxDB和LogAttribute。
请帮我解决这个问题。这是当我尝试为用户创建auth时所遇到的错误。
浏览 1提问于2022-01-14得票数 0
我是Prometheus/Grafana世界的新手，我想从我的node.js应用程序中获得度量指标，我使用来获得如下所示的指标。工作:-)
因此，我想知道是否有人知道我需要将度量标准推送到端点2的格式，或者我如何将格式从prom-cl
浏览 26提问于2022-10-26得票数 0
回答已采纳
我使用的是tdengine和influx，我希望将数据从流入db传输到tdengine。因为从进水数据库读取数据，然后写到tdengine，花费了大量的时间。我知道influxdb支持无模式，并有自己的线路协议。有没有人知道tdengine是否支持influxdb的线路协议？如果有的话，你能给出一些例子吗？
浏览 2提问于2021-11-08得票数 0
回答已采纳
我有大量的流式IoT传感器数据，并且我使用QuestDB作为时间序列数据库。如果我有很多测量数据，我想知道是通过Postgres发送还是通过Influx线路协议发送更好。
浏览 12提问于2021-03-25得票数 1
我正在开发一个生成数据集的应用程序，我想将结果保存到influxdb数据库中，但我没有找到任何有关它的内容。有没有人知道我该从哪里开始？
谢谢您:)
浏览 0提问于2020-09-22得票数 0
", data_format = "influx"data1data3telegraf[14541]: 2018-05-16T16:46:24Z E!
浏览 15提问于2018-05-17得票数 1
希望我没有错过任何官方的lib，因为InfluxDB是由Go编写的。我只是找不到一个可以处理线路协议的Go库。因为我们使用的是InfluxDB的订阅功能，并且它通过Line Protocol传递数据。也没有太多其他简单的选择。
浏览 15提问于2020-01-28得票数 0
我将influxdb2设置为将数据收集到度量"meas0“中。现在，我使用线路协议导入了历史数据，不幸的是，我在目标测量方面做了一个错误，它进入了第二个系列"meas1“。有关字段和标记的结构和名称是相同的。
我在stackoverflox上找到了一个使用influxdb1的fluxQL解决方案。据我所知，这并不适用于新的influxdb2安装！？
浏览 7提问于2022-07-27得票数 0
回答已采纳
我正在使用Python InfluxDBClient来写入InfluxDB服务器。我可以通过JSON或这种所谓的“线路协议”发送数据。
与Json协议相比，使用Line协议有什么优势？有什么不好的地方吗？
浏览 5提问于2021-07-22得票数 0
在将行插入到QuestDB表中时，我遇到了摄取时间问题。当我在第一个文件的空表上插入数据时-大约300k行需要大约60秒的时间。然而，对于第二个文件，它需要更长的时间-180秒。第四个文件超过10分钟。 所有文件在行数上都是相似的。此外，当我只保留一个symbol列时，它看起来更快，但随着插入更多的行，速度会降低： create table trade1 ( buy_order_id string摄取时间似乎与插入的行数一起增长，但在甚至没有定义索引
浏览 82提问于2021-09-09得票数 0
1回答
我正在尝试向InfluxDB发送一些自定义指标(输出为json)，有没有可以用来转换为线路协议的插件或示例脚本？
浏览 0提问于2017-11-22得票数 0
在nifi中，PutInfluxdb处理器可以将数据发送到Influxdb.但是没有什么比fetchInfluxdb/ConsumeInfluxdb处理器更好的了。那么如何将数据从Influxdb推送到hdfs？
浏览 0提问于2018-06-04得票数 0
回答已采纳
我可以使用curl将数据转储到文件中。输出文件是JSON格式的文件，如下所示现在，我修改了JSON以替换一些值。请注意，我没有更改文件的格式。
现在，我如何将其发送回influx以覆盖此记录？
浏览 0提问于2016-12-29得票数 0
我已经看到inputs.http_listener只接受influxDB线路协议。
有没有办法在telegraf上运行监听器的情况下，通过HTTP POST以JSON格式发送数据？
浏览 0提问于2018-03-21得票数 0
我使用一个简单的ExecuteScript脚本(保存为.py文件)在Apache中对NiFi处理器进行了非常基本的设置，如下所示。在处理器的属性中，我将脚本引擎设置为python，脚本文件设置为该脚本的路径。while(count < 20): count = count + 1这是我制作的数据流图但是，我确实在\
浏览 5提问于2016-05-04得票数 12
我希望对大量的客户交易数据进行一些分析。我们有数百万个事务事件，每个实体都有一定的数量和时间戳值； "txId": "tx123" "qty": 3}
我希望在天、周级别和滑动窗口中保留一系列汇总，例如在过去28周内处理的项目i87的sum qty。对于这一点，似乎有许多选择，
浏览 5提问于2016-10-31得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
