Python을 사용하여 InfluxDB를 작동하는 방법에 대한 자세한 설명
- 高洛峰원래의
- 2017-03-14 15:28:0111365검색
환경: 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허브 주소: 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)
Data Operation
InfluxDBClient, 연결할 데이터베이스를 지정해야 합니다. 예시는 다음과 같습니다:
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))
태그와 타임스탬프가 동일한 경우 데이터는 덮어쓰기 작업을 수행합니다. 이는 다음의 업데이트 작업과 동일합니다. 인플럭스DB.
삭제
는 influxql 문 삭제 구문을 사용하여 구현되며, 예시는 다음과 같습니다.
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!