Django + Influxdb

Question

我已经将tseries数据存储在influxdb中，我想通过Web API来提供这些数据，因此正在考虑将Django框架及其REST API框架作为解决方案。

目前，在Django框架上尚无对Influxdb的支持，但是我看到有人暗示在这里的讨论线程中成功创建了该堆栈。

任何关于如何实现此目标的明确评论或想法，都将受到赞赏，尤其是如何将influxdb集成到Django框架中。

Answer 1

您可以在Docker中同时使用Django和InfluxDB。首先，创建一个项目和应用程序。

mkdir django-influxdb-example
cd django-influxdb-example
django-admin startproject project
cd project
django-admin startapp app
cd ..

创建一个虚拟环境并安装django，postgres和influxdb。

python3 -m venv venv
source venv/bin/activate
pip install django psycopg2 influxdb
pip install --upgrade pip
pip freeze > requirements.txt

现在，我的要求看起来像

certifi==2018.8.24
chardet==3.0.4
Django==2.1.1
idna==2.7
influxdb==5.2.0
psycopg2==2.7.5
python-dateutil==2.7.3
pytz==2018.5
requests==2.19.1
six==1.11.0
urllib3==1.23

创建Dockerfile，

FROM python:3.6-alpine3.7

ENV PYTHONUNBUFFERED 1

RUN apk update \
    && apk add libpq postgresql-dev \
    && apk add build-base

WORKDIR /usr/src/app

COPY requirements.txt ./
RUN pip install -r requirements.txt

COPY project ./

创建一个docker-compose.yml文件，

version: '3'

services:

  db:
    image: postgres

  web:
    build: .
    command: python3 manage.py runserver 0.0.0.0:8000
    volumes:
      - ./project:/usr/web/app
    ports:
      - "8000:8000"
    depends_on:
      - db
      - influxdb
    links:
      - influxdb

  influxdb:
    image: influxdb
    ports:
      - "8083:8083"
      - "8086:8086"

我将以下内容添加到了Django中settings.py，

INFLUXDB_HOST = 'influxdb'
INFLUXDB_PORT = 8086
INFLUXDB_USERNAME = None
INFLUXDB_PASSWORD = None
INFLUXDB_DATABASE = 'example'
INFLUXDB_TIMEOUT = 10

在这一点上，您可以尝试构建整个东西，看看它是否出现，

docker-compose build
docker-compose run web python3 manage.py makemigrations
docker-compose run web python3 manage.py migrate
docker-compose up

如果您访问localhost：8000，则应该看到默认的Django初始页面。如果您在Web容器上打开交互式Python会话，则应该能够通过Python influxdb模块访问InfluxDB ，

docker-compose run web python3
Starting django-influxdb-example_db_1 ... done
Starting django-influxdb-example_influxdb_1 ... done
Python 3.6.6 (default, Sep 12 2018, 02:19:14)
[GCC 6.4.0] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> from influxdb import InfluxDBClient
>>> client = InfluxDBClient('influxdb', 8086)
>>> client.get_list_database()
[{'name': '_internal'}]
>>> client.create_database('example')
>>> client.get_list_database()
[{'name': '_internal'}, {'name': 'example'}]

现在一切都已连接并且正在运行，您可以专注于编写代码以创建数据库并添加点。我浏览了django-influxdb-metrics的代码，找到了下面的代码，并将其放在目录中的utils.py文件中app/。这将使用我们在settings.py文件中前面定义的常量创建一个influxdb客户端。

from django.conf import settings

from influxdb import InfluxDBClient

import logging
logger = logging.getLogger(__name__)


def get_influxdb_client():
    """Returns an ``InfluxDBClient`` instance."""
    client = InfluxDBClient(
    settings.INFLUXDB_HOST,
    settings.INFLUXDB_PORT,
    settings.INFLUXDB_USERNAME,
    settings.INFLUXDB_PASSWORD,
    settings.INFLUXDB_DATABASE,
    timeout=getattr(settings, 'INFLUXDB_TIMEOUT', 10),
    ssl=getattr(settings, 'INFLUXDB_SSL', False),
    verify_ssl=getattr(settings, 'INFLUXDB_VERIFY_SSL', False),
)
return client

最后，从这里，我可以通过客户端创建数据库，添加点并执行查询。