Python操作InfluxDB

from influxdb import InfluxDBClient

client = InfluxDBClient(‘localhost‘, 8086, ‘username‘, ‘password‘, ‘dbname‘)

# 显示已存在的数据库
print(client.get_list_database())
# 创建数据库
client.create_database(‘py_db1‘)
print(client.get_list_database())
# 删除数据库
client.drop_database(‘py_db1‘)
print(client.get_list_database())

# 待写入数据库的点组成的列表
points = [
    {
        ‘measurement‘: ‘table1‘,
        ‘tags‘: {
            ‘host‘: ‘server01‘,
            ‘region‘: ‘us-west‘
        },
        ‘time‘: ‘2021-04-16T12:00:00Z‘,
        ‘fields‘: {
            ‘value‘: 0.64
        }
    }
]

# 将这些点写入指定database
client.write_points(points, database=‘py_db1‘)

# 查询刚刚写入的点
result = client.query(‘select value from table1;‘, database=‘py_db1‘)

print(result)

[{‘name‘: ‘_internal‘}, {‘name‘: ‘db0415‘}, {‘name‘: ‘mydb‘}]
ResultSet({‘(‘table1‘, None)‘: [{‘time‘: ‘2021-04-16T12:00:00Z‘, ‘value‘: 0.64}]})