问题标签 [influxdb-python]

我正在尝试向 InfluxDB 发送一些自定义指标（输出 json），是否有任何插件或示例脚本可用于转换为 Line 协议？

我正在尝试将大量行（160.000.000+）从 influxDB 导出到 csv 文件。到目前为止，我只是在运行查询的机器上炸毁内存。我不知道如何在不破坏运行导出的机器的内存的情况下导出这么多行。对此有什么想法吗？？我也尝试过 CLI，但没有任何运气。

我试过下面的代码..

关于如何成功导出数据的任何提示或提示。

我想将 CSV 文件中的数据发布到 InfluxDB 文件，并且 InfluxDB 的时间列应与 CSV 文件时间列匹配。我的意思是 InfluxDB 时间序列应该与 CSV 文件的时间序列相同。

我的主要动机是 InfluxDB 应该根据 CSV 文件的时间序列存储 CSV 文件的数据。

CSV 文件如下所示

我已使用此香料代码将 CSV 文件的时间转换为纪元以发送 InfluxDB 服务器

我已将这些数据以 JSON 格式发布到 InfluxDB 服务器。

将这些数据发布到 InfluxDB 服务器没有问题，但是当我使用数据库面板中的此查询检查是否将正确的数据写入 Influxdb 时。

influxDB 向我显示了这个“2018-01-04T05:43:41.580065574Z”时间，但它应该向我显示“2017-12-26 07:34:27”，与 CSV 文件的时间相同。

请告诉我，我可以通过哪种方法匹配 CSV 和 InfluxDB 的时间？

请告诉我我可以用哪种方法做我想做的事情？

如何遍历从 influxDB 返回的结果集？我通过使用得到这个结果

结果集（{'（u'cpu'，无）'：[{u'usage_guest_nice'：0，u'usage_user'：0.90783871790308868，u'usage_nice'：0，u'usage_steal'：0，u'usage_iowait'：0.056348610076366427 , u'host': u'xxx.xxx.hostname.com', u'usage_guest': 0, u'usage_idle': 98.184322579062794, u'usage_softirq': 0.0062609566755314457, u'time': u'2016-06-26T16 :25:00Z', u'usage_irq': 0, u'cpu': u'cpu-total', u'usage_system': 0.84522915123660536}]})

我想获取usage_user 值、usage_system 值等并将它们插入到数组中。

我正在尝试向 influxDB TSDB 写入点，但是在写入过程中它给出了一个错误：

我有以下 JSON 点：

我有以下代码：

raw_metric 看起来像这样：

字段如下所示：

标签看起来像这样：

关于为什么我收到部分写入错误的任何想法？

我想在我的 SELECT 语句中创建一个动态 WHERE 子句。

查看 Google 结果和 InfluxDB 文档，我找不到任何提及 COALESCE 或任何等效/合理的方式来实现此目的。

这样做的首选方法是什么？

将模拟这一点的 Python 库足以满足我的目的，但我更喜欢纯“SELECT”示例。

我在 InfluxDB 中有一些带有列Ticker和Price. 例如：

我想提取每只股票的最新价格，即使它们可能在不同的时间。所以最终的选择应该是这样的

在常规 SQL 中，通常会这样做：

问题是，Influx 似乎不支持INNER JOIN或任何其他类型的加入。我刚刚开始学习它，对于时间序列数据库，这种类型的问题必须是它构建的最常见的问题之一。你如何快速做到这一点？

速度是我关心的问题，因为我正在查看表中大约 5-1500 万行，以及 150,000 个不同的代码（并非所有都是股票，我存储了很多工具）。

非常感谢。

PS 如果重要，我将通过 Python API 访问 Influx，并且可以在代码中进行此过滤，但强烈希望在 DB 端进行此操作，以尽量减少通过网络传输大量行...

更新

我看到了这个关于左连接的问题，但它似乎已经过时了，我需要一个内在的，答案特别暗示的东西会得到支持......

可能的方法

这行得通吗？

如果是的话，它在一张大桌子上的速度有多快（参见上面的测量值）？

在 Python 中正确构建 InfluxDB 查询的首选方法是什么？

（我一直在寻找合适的 InfluxDB 查询生成器。我发现的那些要么是旧的/过时的，要么不能真正为 InfluxDB 生成有效的查询。）

在 influxdb 1.5 中，路径可以接受请求/write中的多个点。POST

对此合理的最大有效载荷大小是多少？100分？1,000？10,000？更多的？

最近开始研究 influxDB，找不到如何添加新的测量值或从单独的测量值制作数据表，比如在 SQL 中我们必须连接表左右。

influxdb文档不是那么清楚。我目前正在使用终端进行所有操作，不介意切换到 python，但其中大部分是关于文档中的 HTTP 发布方案，还有其他选择吗？

如果社区支持很好，我更喜欢 python 中的 influxDB