Python을 사용하여 InfluxDB를 작동하는 방법에 대한 자세한 설명-파이썬 튜토리얼-php.cn

Python을 사용하여 InfluxDB를 작동하는 방법에 대한 자세한 설명

高洛峰

풀어 주다： 2017-03-14 15:28:01

원래의

11384명이 탐색했습니다.

환경: 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(&#39;localhost&#39;, 8086, &#39;root&#39;, &#39;&#39;, &#39;&#39;) # 初始化
print client.get_list_database() # 显示所有数据库名称
client.create_database(&#39;testdb&#39;) # 创建数据库
print client.get_list_database() # 显示所有数据库名称
client.drop_database(&#39;testdb&#39;) # 删除数据库
print client.get_list_database() # 显示所有数据库名称

로그인 후 복사

테이블 작업

데이터베이스 연결 대상은 InfluxDBClient에 지정됩니다.

client = InfluxDBClient(&#39;localhost&#39;, 8086, &#39;root&#39;, &#39;&#39;, &#39;testdb&#39;) # 初始化（指定要操作的数据库）

로그인 후 복사

지정된 데이터베이스의 기존 테이블을 표시합니다

influxql 문을 통해 달성할 수 있으며 예는 다음과 같습니다.

result = client.query(&#39;show measurements;&#39;) # 显示数据库中的表print("Result: {0}".format(result))

로그인 후 복사

새로운 테이블 및 데이터 추가

InfluxDB는 별도의 테이블 생성문을 제공하지 않으며, 데이터를 추가하여 테이블을 전달하고 생성할 수 있으며, 예시는 다음과 같습니다.

json_body = [
    {
        "measurement": "students",
        "tags": {
            "stuid": "s123"
        },
        #"time": "2017-03-12T22:00:00Z",
        "fields": {
            "score": 89
        }
    }
]

client = InfluxDBClient(&#39;localhost&#39;, 8086, &#39;root&#39;, &#39;&#39;, &#39;testdb&#39;) # 初始化（指定要操作的数据库）
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(&#39;localhost&#39;, 8086, &#39;root&#39;, &#39;&#39;, &#39;testdb&#39;) # 初始化（指定要操作的数据库）
showDBNames(client)
client.write_points(json_body) # 写入数据，同时创建表
showDBNames(client)
client.query("drop measurement students") # 删除表
showDBNames(client)

로그인 후 복사

Data Operation

InfluxDBClient, 연결할 데이터베이스를 지정해야 합니다. 예시는 다음과 같습니다:

client = InfluxDBClient(&#39;localhost&#39;, 8086, &#39;root&#39;, &#39;&#39;, &#39;testdb&#39;) # 初始化（指定要操作的数据库）

로그인 후 복사

추가는 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(&#39;select * from students;&#39;)    
print("Result: {0}".format(result))

로그인 후 복사

업데이트

태그와 타임스탬프가 동일한 경우 데이터는 덮어쓰기 작업을 수행합니다. 이는 다음의 업데이트 작업과 동일합니다. 인플럭스DB.

삭제

는 influxql 문 삭제 구문을 사용하여 구현되며, 예시는 다음과 같습니다.

client.query(&#39;delete from students;&#39;) # 删除数据

로그인 후 복사

데이터 연산의 전체 예는 다음과 같습니다.

#! /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(&#39;delete from students;&#39;) # 删除数据
showDatas(client)  # 查询数据

로그인 후 복사

네, 이상입니다. 도움이 되셨으면 좋겠습니다.

위 내용은 Python을 사용하여 InfluxDB를 작동하는 방법에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!