python連線，操作 InfluxDB

執行如下命令：

service influxdb start

[root@localhost ~]# service influxdb start

starting influxdb...
influxdb process was started [ ok ]
[root@localhost ~]#

安裝pip ： 

yum install python-pip

pip install influxdb

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

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

json_body =[

,#"time": "2017-03-12t22:00:00z",
"fields": 
}]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 =[
,#"time": "2017-03-12t22:00:00z",
"fields": 
}]def
showdbnames(client):
result = client.query(『
show measurements;
『) #
顯示資料庫中的表
print("
result: 
".format(result))
client = influxdbclient(『
localhost
『, 8086, 『
root
『, 『『, 『
testdb
『) #
初始化（指定要操作的資料庫）
showdbnames(client)
client.write_points(json_body) 
#寫入資料，同時建立表
showdbnames(client)
client.query(
"drop measurement students
") #
刪除表showdbnames(client)

influxdbclient中要指定連線的資料庫，示例如下：

client = influxdbclient(『

localhost
『, 8086, 『
root
『, 『『, 『
testdb
『) #
初始化（指定要操作的資料庫）

可以通過write_points實現，示例如下：

json_body =[

,#"time": "2017-03-12t22:00:00z",
"fields": 
}]client.write_points(json_body) 
#寫入資料

可以通過influxql語句實現，示例如下：

result = client.query(『

select * from students;
『) 
print("
result: 
".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 =[
,#"time": "2017-03-12t22:00:00z",
"fields": 
}]def
showdatas(client):
result = client.query(『
select * from students;『)
print("
result: 
".format(result))
client = influxdbclient(『
localhost
『, 8086, 『
root
『, 『『, 『
testdb
『) #
初始化client.write_points(json_body) #
寫入資料
showdatas(client) #
查詢資料
client.query(『
delete from students;
『) #
刪除資料
showdatas(client) #
查詢資料

Python連線ORACLE操作

一 準備工作 1 安裝cx oracle 執行安裝命令 pip install cx oracle 6.0rc1 cp35 cp35m win amd64.whl 2 安裝oracle，並建使用者test test lu 二 編寫py檔案 import cx oracle conn cx oracl...

python連線MySQL基本操作

import pymysql 建立連線 db pymysql.connect localhost root 123456 test sql select from score where id 10 建立游標物件 cur db.cursor 指定執行sql a cur.execute sql 這個是...

python 連線sqlite及操作

import sqlite3 查詢def load table 連線資料庫 con sqlite3.connect e datebase sqlitestudio park.db 獲得游標 cur con.cursor 查詢整個表 cur.execute select from table list...