使用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()) #顯示所有資料庫名稱
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的更新操作
36. # 6 刪除
37. # 使用influxql語句實現，delete語法，示例如下"
38. # client.query('delete from students;') #刪除資料