使用Python操作InfluxDB時序數據庫

安裝python包

influxdb，這里我安裝的是5.3.0版本

pip install influxdb==5.3.0

 

使用

1. from influxdb import InfluxDBClient
2. conn_db=InfluxDBClient( '127.0.0.1', '8086', 'u_wyk13195', 'p_wyk13195', 'my_monitor')
3. 1 #數據庫操作
4. conn_db.create_database( 'testdb') #創建數據庫
5. print(conn_db.get_list_database()) #顯示所有數據庫名稱
6. conn_db.drop_database( 'testdb') #刪除數據庫
7. print(conn_db.get_list_database()) #顯示所有數據庫名稱
8.  
9. 2 #表操作
10. #influxDB沒有提供單獨的建表語句，可以通過並添加數據的方式建表，示例如下:
11. json_body = [
12. {
13. "measurement": "students",
14. "tags": {
15. "stuid": "s123"
16. },
17. #"time": "2017-03-12T22:00:00Z",
18. "fields": {
19. "score": 89
20. }
21. }
22. ]
23.  
    conn_db.write_points(json_body) #寫入數據，同時創建表
24. result = conn_db.query( "show measurements") #顯示數據庫中的表
25. print( "Result: {}".format(result))
26. 3 #查詢:可以通過influxql語句實現，示例如下：
27. result = conn_db.query( 'select * from students;')
28. print( "Result: {0}".format(result))
29. 4 #通過influxql語句實現
30. conn_db.query( 'drop measurement students') #刪除表
31. result = conn_db.query( "show measurements") #顯示數據庫中的表
32. print( "Result: {}".format(result))
33. # 5 更新
34.  
    # tags和timestamp相同時數據會覆蓋操作，相當於influxDB的更新操作
35.  
36.  
    # 6 刪除
37.  
    # 使用influxql語句實現，delete語法，示例如下"
38.  
    # client.query('delete from students;') #刪除數據