关于python3.x:python3-使用influxdb12

44次阅读

共计 907 个字符，预计需要花费 3 分钟才能阅读完成。

import json
import datetime
import requests, os
from influxdb import InfluxDBClient

DataBasename = "test"

conn_db = InfluxDBClient('10.26.5.35', '8086', 'lixx', '12xx456', DataBasename)

#conn_db.create_database('testdb')    #创立数据库
print(conn_db.get_list_database())    #显示所有数据库名称

#conn_db.drop_database('testdb')       #删除数据库
#print("##test delet after:", conn_db.get_list_database())

json_body = [
    {
        "measurement": "ipad_electricitytable",
        "tags": {
            "ip": "10.31.140.24",
            "device_id": "sn:222ss222test",
            "device_type": "ipad"
                 },
        "fields": {"electricity": 79}
        }
]

conn_db.write_points(json_body)    #写入数据，同时创立表




result = conn_db.query('select * from ipad_electricitytable;') ##select
print("Result: {0}".format(result))



#conn_db.query('drop measurement students')    #删除表
result = conn_db.query("show measurements")    #显示数据库中的表
print("Result: {0}".format(result))


#5、更新
#tags 和 timestamp 雷同时数据会笼罩操作，相当于 influxDB 的更新操作

#6、删除
#应用 influxql 语句实现，delete 语法，示例如下 "#conn_db.query('delete from ipad_electricitytable;')    #删除数据

正文完