InfluxDB JSON 数据摄取到测量中

Question

我正在尝试使用 influxDB python 客户端将数据从一个测量（漏洞）提取到另一个测量（test1）。由于我只想提取服务器、ID、从漏洞测量到 test1 测量的路由，因此我选择三列。任何关于如何将数据从一个测量摄取到另一个测量的帮助将不胜感激。

代码：

from influxdb import InfluxDBClient
from datetime import datetime
client = InfluxDBClient('hostname', 8089, 'user', 'pwd', 'database')
results = client.query("SELECT server, ID, route from vulnerability") 
for row in results:
    influxJson = [
                    {
                        "measurement":"test1",  
                        "time" : datetime.utcnow().isoformat() + "Z",
                        "tags": {
                            'ResiliencyTier':'targetResiliencyTier',
                            'lob' : 'technologyDivision'
                        },
                        "fields": {
                            columns[0][0] : str(row[1][0]),
                            columns[1][0] : str(row[1][1]),
                            columns[2][0] : str(row[1][2])

                        }
                    }
                ]
client.write_points(influxJson) 

漏洞测量示例数据：

{'time': '2022-02-10T17:51:52.638000Z', 'server': '123123123', 'id': '351335', 'route': '37875'}, {'time': '2022-02-10T17:51:52.638000Z', 'server': '234', 'qid': '351343', 'route': '0037875'}

错误：

  File "Vul_SUmmary_UTEP_data_PROD.py", line 29, in startprocess
    columns[0][0] : str(row[1][0]),
NameError: name 'columns' is not defined

谢谢

Answer 1

关于错误（我知道有点晚了），它明确指出 'columns' 未定义。那是因为它从来都不是。 'row' 被定义是因为它是 for 循环的变量。如果你想用行中的数据填充另一个表，你需要事先定义它。您也可以只写：

'server' : str(row[1][0]),
'ID' : str(row[1][1]),
'route' : str(row[1][2])

毕竟，您只是想为 fields 创建另一个字典。

我希望你在过去 5 个月里自己已经弄清楚了这一点。我刚刚偶然发现你关于另一个问题的问题。