InfluxDBきほんのき

最近Grafanaを弄っている流れでInfluxDBも触っています。
結構くせがあったのでInfluxDBについてまとめることにしました。

インストール

rpmやdpkg、macだったらbrewでサクッと入れられます。

InfluxDB | Installation

• REHL系の例

rpm -ivh http://s3.amazonaws.com/influxdb/influxdb-latest-1.x86_64.rpm

GUI

InfluxDBにはWebの管理GUIが同梱されています。
デフォルトでは
http://localhost:8083
でアクセスできます。

初期のユーザとパスワードは公式ドキュメントに記載があるようにroot/rootです。
ホスト名にはブラウザで開いたホストと同じもの、ポートには8086を指定してconnectします。

データベースの作成

InfluxDBのデータベースはRDBのスキーマの概念に近いです。

GUI経由でのデータベースの作成

connectするとデータベース一覧と登録フォームが表示されます。

ここでデータベース名を入力し、Create Databaseを行うとデータベースを作成することができます。

REST API経由でのデータベースの作成

curlを使った例です。JSONを-dでPOSTします。

curl -X POST 'http://localhost:8086/db?u=root&p=root' -d '{"name": "test"}'

ユーザの作成

GUI経由でのユーザの作成

データベース・ユーザを作成します。
データベースを選択するとユーザ一覧と登録フォームが表示されます。

ここでユーザ名とパスワードを入力し、Createを行うとデータベース・ユーザを作成することができます。
AdminにチェックするとAdminユーザとなります。
Adminユーザはデータベースやユーザを作成／削除したり、パーミッションを変更したりすることができます。

REST API経由でのユーザの作成

パスが/db/データベース名/usersになります。

curl -X POST 'http://localhost:8086/db/test/users?u=root&p=root' -d '{"name": "test", "password": "パスワード"}'

データの登録・WRITE

InfkuxDBではseriesごとにデータを登録します。
seriesとはRDBのテーブルに近い概念です。
timeカラムを指定して登録すれば指定した時刻のデータを登録することができます。

GUI経由でのデータ登録

データベース一覧からExplore Data »をタップします。
Time Series Nameにseries名を入力し、
Write PointにJSONを入力してボタンをタップします。
JSONの形式は{"カラム名": 値, ・・・}です。

REST API経由でのデータ登録

パスが/db/データベース名/seriesになります。
JSONをPOSTするのですがGUIのJSONと形式が異なります。

[
  {
    "name": "series名",
    "columns": [カラム名を配列で、、],
    "points": [
      [カラム１の値、カラム２の値・・・],
      :
    ]
  }
]

curl -X POST 'http://localhost:8086/db/test/series?u=root&p=root' -d \
'{"name": "nikkei_average", "columns": ["time", "price"], "points": [[1418083200000, 17450.77]]}'

データの上書きを行うときはtime, sequence_numberを指定してWRITEします。

curl -X POST 'http://localhost:8086/db/test/series?u=root&p=root' -d \
'{"name": "nikkei_average", "columns": ["time", "sequence_number", "price"], "points": [[1418083200000, 69260001, 17450.77]]}'

クエリ・SELECT

GUI経由でのクエリ

データ登録と同様、データベース一覧からExplore Data »をタップします。
Read Pountsにクエリを入力し、Execute Queryをタップします。

時系列グラフと結果が一覧で表示されます。

REST API経由でのクエリ

パスはデータ登録と同じく/db/データベース名/seriesになります。
HTTPメソッドがGETになり、QueryString:q=でクエリを渡します。

curl -G 'http://localhost:8086/db/test/series?u=root&p=root' -d --data-urlencode "select * from nikkei_average"

結果がJSONで表示されます。

[{"name":"nikkei_average","columns":["time","sequence_number","price"],"points":[[1419778800000,69270001,17729.84],[1419519600000,69280001,17818.96],[1418083200000,69260001,17450.77]]}]

見づらいのでpretty=trueをQueryStringに追加するとインデント表示されます。

curl -G 'http://localhost:8086/db/test/series?u=root&p=root&pretty=true' -d --data-urlencode "select * from nikkei_average"

[
    {
        "name": "nikkei_average",
        "columns": [
            "time",
            "sequence_number",
            "price"
        ],
        "points": [
            [
                1419778800000,
                69270001,
                17729.84
            ],
            [
                1419519600000,
                69280001,
                17818.96
            ],
            [
                1418083200000,
                69260001,
                17450.77
            ]
        ]
    }

ユーザの削除

GUI経由でのユーザの削除

データベース・ユーザを削除します。
ユーザ一覧からXをタップするだけです。

REST API経由でのユーザの削除

パスが/db/データベース名/users/ユーザ名になります。
HTTPメソッドはDELETEを使います。

curl -X DELETE 'http://localhost:8086/db/test/users/dbuser?u=root&p=root'

データベースの削除

GUI経由でのデータベースの削除

データベースを削除します。
ユーザの削除と同じくデータベース一覧からXをタップするだけです。

REST API経由でのデータベースの削除

パスが/db/データベース名になります。
HTTPメソッドはDELETEを使います。

curl -X DELETE 'http://localhost:8086/db/test?u=root&p=root'