使用python操作InfluxDB

古城微笑少年丶 2021-11-09 09:24 541阅读 0赞

参考链接:[https://github.com/mike-zhang/mikeBlogEssays/blob/master/2017/20170312\_使用python操作InfluxDB.md][https_github.com_mike-zhang_mikeBlogEssays_blob_master_2017_20170312_python_InfluxDB.md]

python针对influxdb的操作
    from influxdb import influxDBClient
    conn_db=InfluxDBClient('localhost','8086','username','password','db_name')
    
    1、显示已存在的所有数据库
    使用get_list_database函数，
    print conn_db.get_list_database()    #显示所有数据库名称
    
    2、创建新数据库
    使用create_database函数，示例如下:
    conn_db.create_database('testdb')    #创建数据库
    
    3、删除数据库
    使用drop_database函数，示例如下:
    conn_db.drop_database('testdb')       #删除数据库
    
    表操作
    influxDBClient中要指定连接的数据库
    1、显示指定数据库中已存在的表，可以通过influxql语句实现，示例如下:
    result = conn_db.query("show measurements")    #显示数据库中的表
    print("Result: {0}".format(result))   
    
    2、创建新表并添加数据
    influxDB没有提供单独的建表语句，可以通过并添加数据的方式建表，示例如下:
    json_body = [
        {
            "measurement": "students",
            "tags": {
                "stuid": "s123"
            },
            #"time": "2017-03-12T22:00:00Z",
            "fields": {
                "score": 89
            }
        }
    ]
    conn_db.write_points(json_body)    #写入数据，同时创建表
    
    3、删除表
    可以通过influxql语句实现，示例如下:
    conn_db.query('drop measurement students')    #删除表
    
    4、查询:
    可以通过influxql语句实现，示例如下：
    result = conn_db.query('select * from students;')    
    print("Result: {0}".format(result))
    
    5、更新
    tags和timestamp相同时数据会覆盖操作，相当于influxDB的更新操作
    
    6、删除
    使用influxql语句实现，delete语法，示例如下"
    client.query('delete from students;')    #删除数据

作者：小王同学123321  
链接：https://www.jianshu.com/p/f9646d297725  
来源：简书  
简书著作权归作者所有，任何形式的转载都请联系作者获得授权并注明出处。

[https_github.com_mike-zhang_mikeBlogEssays_blob_master_2017_20170312_python_InfluxDB.md]: https://links.jianshu.com/go?to=https%3A%2F%2Fgithub.com%2Fmike-zhang%2FmikeBlogEssays%2Fblob%2Fmaster%2F2017%2F20170312_%25E4%25BD%25BF%25E7%2594%25A8python%25E6%2593%258D%25E4%25BD%259CInfluxDB.md