python對influxdb的相關操作

2021-10-21 02:19:33 字數 1237 閱讀 9979

from influxdb import influxdbclient

conn_db=influxdbclient(『localhost』,『8086』,『username』,『password』,『dbname』)

#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: 」.format(result))

#2、建立新錶並新增資料

#influxdb沒有提供單獨的建表語句,可以通過並新增資料的方式建表,示例如下:

json_body = [

,#「time」: 「2017-03-12t22:00:00z」,

「fields」: }]

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: 」.format(result))

#5、更新

#tags和timestamp相同時資料會覆蓋操作,相當於influxdb的更新操作

#6、刪除

#使用influxql語句實現,delete語法,示例如下"

#client.query(『delete from students;』) #刪除資料加粗樣式

python連線,操作 InfluxDB

執行如下命令 service influxdb start示例如下 root localhost service influxdb start starting influxdb.influxdb process was started ok root localhost 安裝pip yum ins...

python操作influxdb插入資料失敗問題

最近做實時和離線資料監控,對比離線和實時的資料量是否一致,用python呼叫第三方influxdb包插入到influxdb時序資料庫,碰到一些問題。influxdb的表叫measurements,不需要建立,只要插入資料,會自動生成。python插入inluxdb 大概如下 from influxd...

InfluxDB系列(一)influxDB簡介

influxdb是乙個由influxdata用go語言開發的開源時序型資料庫,專注於海量時序資料的高效能讀 高效能寫 高效儲存與實時分析等,無需外部依賴。主要特點 1 基於時間序列,支援與時間有關的相關函式 如最大,最小,求和等 2 可度量性 你可以實時對大量資料進行計算 設計理念 優缺點優勢 架構...