環境： CentOS6.5_x64
InfluxDB版本：1.1.0
Python版本：2.6
##準備工作
啟動伺服器-
執行以下指令：
service influxdb start
登入後複製
範例如下：
[root@localhost ~]# service influxdb start
Starting influxdb...
influxdb process was started [ OK ]
[root@localhost ~]#
登入後複製
#安裝
influxdb-python
#git
hub位址：
https://
github.com/influxdata/influxdb-python
安裝pip ： -
yum install python-pip
登入後複製
安裝influxdb-python ：
pip install influxdb
登入後複製
基本操作
InfluxDBClient類別作業資料庫，範例如下：
from influxdb import InfluxDBClient
client = InfluxDBClient('localhost', 8086, 'root', '', '') # 初始化登入後複製
#顯示已存在的所有資料庫-
## 使用get_list_database
函數
，範例如下：
print client.get_list_database() # 顯示所有資料庫名稱
- 建立新資料庫
使用create_database函數，範例如下：
client.create_database('testdb')
#建立資料庫
刪除
資料庫
使用drop_database函數，範例如下：
client.drop_database('testdb') # 刪除資料庫
#資料庫操作- 完整範例如下：
#! /usr/bin/env python
#-*- coding:utf-8 -*-
from influxdb import InfluxDBClient
client = InfluxDBClient('localhost', 8086, 'root', '', '') # 初始化
print client.get_list_database() # 显示所有数据库名称
client.create_database('testdb') # 创建数据库
print client.get_list_database() # 显示所有数据库名称
client.drop_database('testdb') # 删除数据库
print client.get_list_database() # 显示所有数据库名称
登入後複製
#InfluxDBClient中要指定連接的資料庫，範例如下：
client = InfluxDBClient('localhost', 8086, 'root', '', 'testdb') # 初始化（指定要操作的数据库）
登入後複製
登入後複製
可以透過influxql語句實現，範例如下：
result = client.query('show measurements;') # 显示数据库中的表print("Result: {0}".format(result))登入後複製
InfluxDB沒有提供單獨的建表語句，可以通過並新增資料的方式建表，範例如下：
json_body = [
{
"measurement": "students",
"tags": {
"stuid": "s123"
},
#"time": "2017-03-12T22:00:00Z",
"fields": {
"score": 89
}
}
]
client = InfluxDBClient('localhost', 8086, 'root', '', 'testdb') # 初始化（指定要操作的数据库）
client.write_points(json_body) # 写入数据，同时创建表登入後複製
#刪除表
##可以透過influxql語句實現，範例如下：
client.query("drop measurement students") # 删除表登入後複製
#資料表操作
完整範例如下：
#! /usr/bin/env python
#-*- coding:utf-8 -*-
from influxdb import InfluxDBClient
json_body = [
{
"measurement": "students",
"tags": {
"stuid": "s123"
},
#"time": "2017-03-12T22:00:00Z",
"fields": {
"score": 89
}
}
]
def showDBNames(client):
result = client.query('show measurements;') # 显示数据库中的表
print("Result: {0}".format(result))
client = InfluxDBClient('localhost', 8086, 'root', '', 'testdb') # 初始化（指定要操作的数据库）
showDBNames(client)
client.write_points(json_body) # 写入数据，同时创建表
showDBNames(client)
client.query("drop measurement students") # 删除表
showDBNames(client)登入後複製
資料操作
client = InfluxDBClient('localhost', 8086, 'root', '', 'testdb') # 初始化（指定要操作的数据库）
登入後複製
登入後複製
新增
- 可以透過write_points實現，範例如下：
json_body = [
{
"measurement": "students",
"tags": {
"stuid": "s123"
},
#"time": "2017-03-12T22:00:00Z",
"fields": {
"score": 89
}
}
]
client.write_points(json_body) # 写入数据登入後複製
##查詢
可以透過influxql語句實現，範例如下：
result = client.query('select * from students;')
print("Result: {0}".format(result))登入後複製
###更新###############tags 和timestamp相同時資料會執行覆寫操作，相當於InfluxDB的更新操作。 ############刪除############使用influxql語句實現，###delete###語法，範例如下：######## #
client.query('delete from students;') # 删除数据
登入後複製
#########資料操作完整範例如下：###
#! /usr/bin/env python
#-*- coding:utf-8 -*-
from influxdb import InfluxDBClient
json_body = [
{
"measurement": "students",
"tags": {
"stuid": "s123"
},
#"time": "2017-03-12T22:00:00Z",
"fields": {
"score": 89
}
}
]
def showDatas(client):
result = client.query('select * from students;')
print("Result: {0}".format(result))
client = InfluxDBClient('localhost', 8086, 'root', '', 'testdb') # 初始化
client.write_points(json_body) # 写入数据
showDatas(client) # 查询数据
client.query('delete from students;') # 删除数据
showDatas(client) # 查询数据登入後複製
#########好，就這些了，希望對你有幫助。 ############
以上是詳解使用python操作InfluxDB方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！
