2

我正在使用 InfluxDb 并且有简单的线路协议线路，如下所示：

cpu,atag=test1 idle=100,usertime=10,system=1

我有使用字典的python客户端，如下所示

client = InfluxDBClient(host, port, USER, PASSWORD, DBNAME)
client.create_database(DBNAME)

tagdic= {'Name': 'n1', 'data': 7}
fielddic= {'Name': 'field', 'f1': 70}
def main():
    var = 1
    while var == 1 :  
     client.write("cpu,atag=test1 idle=100,usertime=10,system=1")
     #client.write_points([{"measurement": "cpu", "tags": tagdic, "fields": fielddic}])

只要我使用 write_points 和字典来使用 write_points，上面的程序就可以正常工作，但是当我使用 client.write 时，我遇到了错误。

我如何通过使用协议值='line'而不是默认协议'json'来使用client.write（行号-255 ）？

4

1 回答 1

7

你得到什么错误？这是非常重要的信息。

你得到：

influxdb.exceptions.InfluxDBClientError: 400: {"error":"database is required"}

然后你应该这样写你的电话：

client.write(['cpu,atag=test1 idle=100,usertime=10,system=1'],{'db':DBNAME},204,'line')

我改变的事情：

  • 线路协议字符串必须在列表中。
  • 不知何故，您需要将数据库名称添加到额外的参数中。我不确定这是临时的“错误”还是预期的功能。
  • 您必须将协议设置为“线”（这也迫使您设置预期的返回码，因为这是协议之前的位置参数）

给 ubuntu 用户的注意事项：如果您在撰写本文时使用 ubuntu 包管理器进行安装，您将获得较旧版本的 python 客户端，其中 write 函数采用其他参数。因此，如有疑问，请使用 pip 安装。

于 2017-02-17T15:16:18.210 回答