使用 Docker-Compose 快速上手

    安装

    提示

    如果您已经有一安装好的 Docker，可以跳过这一步

    浏览查阅 ，然后 安装到您的操作系统上。安装时，请注意检查您的设备是否满足所有的前置条件。

    确认 Docker daemon 正在运行：

    提示

    在 Linux，Docker 需要 root 权限。当然，你也可以以非 root 用户的方式运行 Docker，详情可以参考 Post-installation steps for Linux快速上手 - 图2 (opens new window)。

    安装 docker-compose

    提示

    如果您已经有一安装好的 Docker Compose，可以跳过这一步

    注意

    请不要在生产环境中使用以下配置

    创建一个 quick-start.yaml, 可以直接或者复制以下内容:

    1. # quick-start.yaml
    3. version: "3.5"
    5. services:
    6.   hserver0:
    7.     image: hstreamdb/hstream:v0.11.0
    8.     depends_on:
    9.       - zookeeper
    10.       - hstore
    11.     ports:
    12.       - "127.0.0.1:6570:6570"
    13.     expose:
    14.       - 6570
    15.     networks:
    16.       - hstream-quickstart
    17.     volumes:
    18.       - /var/run/docker.sock:/var/run/docker.sock
    19.       - /tmp:/tmp
    20.       - data_store:/data/store
    21.     command:
    22.       - bash
    23.       - "-c"
    24.       - |
    25.         set -e
    26.         /usr/local/script/wait-for-storage.sh hstore 6440 zookeeper 2181 600 \
    27.         /usr/local/bin/hstream-server \
    28.         --bind-address 0.0.0.0 --port 6570 \
    29.         --internal-port 6571 \
    30.         --server-id 100 \
    31.         --seed-nodes "$$(hostname -I | awk '{print $$1}'):6571,hserver1:6573" \
    32.         --advertised-address $$(hostname -I | awk '{print $$1}') \
    33.         --metastore-uri zk://zookeeper:2181 \
    34.         --store-config /data/store/logdevice.conf \
    35.         --store-admin-host hstore --store-admin-port 6440 \
    36.         --io-tasks-path /tmp/io/tasks \
    37.         --io-tasks-network hstream-quickstart
    39.   hserver1:
    40.     depends_on:
    41.       - zookeeper
    42.       - hstore
    43.     ports:
    44.       - "127.0.0.1:6572:6572"
    45.     expose:
    46.       - 6572
    47.     networks:
    49.     volumes:
    50.       - /var/run/docker.sock:/var/run/docker.sock
    51.       - /tmp:/tmp
    52.       - data_store:/data/store
    53.     command:
    54.       - bash
    55.       - "-c"
    56.       - |
    57.         set -e
    58.         /usr/local/script/wait-for-storage.sh hstore 6440 zookeeper 2181 600 \
    59.         /usr/local/bin/hstream-server \
    60.         --bind-address 0.0.0.0 --port 6572 \
    61.         --internal-port 6573 \
    62.         --server-id 101 \
    63.         --seed-nodes "hserver0:6571,$$(hostname -I | awk '{print $$1}'):6573" \
    64.         --advertised-address $$(hostname -I | awk '{print $$1}') \
    65.         --metastore-uri zk://zookeeper:2181 \
    66.         --store-config /data/store/logdevice.conf \
    67.         --store-admin-host hstore --store-admin-port 6440 \
    68.         --io-tasks-path /tmp/io/tasks \
    69.         --io-tasks-network hstream-quickstart
    71.   hserver-init:
    72.     image: hstreamdb/hstream:v0.11.0
    73.     depends_on:
    74.       - hserver0
    75.       - hserver1
    76.     networks:
    77.       - hstream-quickstart
    78.     command:
    79.       - bash
    80.       - "-c"
    81.       - |
    82.         timeout=120
    83.         until ( \
    84.             /usr/local/bin/hadmin server --host hserver0 --port 6570 status && \
    85.             /usr/local/bin/hadmin server --host hserver1 --port 6572 status \
    86.         ) >/dev/null 2>&1; do
    87.             >&2 echo 'Waiting for servers ...'
    88.             sleep 1
    89.             timeout=$$((timeout - 1))
    90.         done; \
    91.         /usr/local/bin/hadmin server --host hserver0 init
    93.   hstore:
    94.     image: hstreamdb/hstream:v0.11.0
    95.     networks:
    97.     volumes:
    98.       - data_store:/data/store
    99.     command:
    100.       - bash
    101.       - "-c"
    102.       - |
    103.         set -ex
    104.         /usr/local/bin/ld-dev-cluster --root /data/store \
    105.         --use-tcp --tcp-host $$(hostname -I | awk '{print $$1}') \
    106.         --user-admin-port 6440 \
    107.         --no-interactive
    109.   zookeeper:
    110.     image: zookeeper
    111.     expose:
    112.       - 2181
    113.     networks:
    114.       - hstream-quickstart
    115.     volumes:
    116.       - data_zk_data:/data
    117.       - data_zk_datalog:/datalog
    119. networks:
    120.   hstream-quickstart:
    121.     name: hstream-quickstart
    123. volumes:
    124.   data_store:
    125.     name: quickstart_data_store
    126.   data_zk_data:
    127.     name: quickstart_data_zk_data
    128.   data_zk_datalog:
    129.     name: quickstart_data_zk_datalog

    在同一个文件夹中运行：

    1. docker-compose -f quick-start.yaml up

    如果出现如下信息，表明现在已经有了一个运行中的 HServer：

    提示

    当然，你也可以选择在后台启动

    1. docker-compose -f quick-start.yaml up -d

    并且可以通过以下命令展示 logs ：

    1. docker-compose -f quick-start.yaml logs -f hserver

    启动 HStreamDB 的 SQL 命令行界面

    1. docker run -it --rm --name some-hstream-cli --network host hstreamdb/hstream:v0.11.0 hstream --port 6570 sql

    首先，我们可以用 CREATE STREAM 语句创建一个名为 demo 的 stream.

    1. CREATE STREAM demo;

    对这个 stream 执行一个持久的查询操作

    现在，我们可以通过 SELECT 在这个 stream 上执行一个持久的查询。

    这个查询的结果将被直接展现在 CLI 中。

    以下查询任务会输出所有 demo stream 中具有 humidity 大于 70 的数据。

    1. SELECT * FROM demo WHERE humidity > 70 EMIT CHANGES;

    现在看起来好像无事发生。这是因为从这个任务执行开始，还没有数据被写入到 demo 中。 接下来，我们会写入一些数据，然后符合条件的数据就会被以上任务输出。

    我们可以利用这个新的 CLI 来插入数据：

    1. docker exec -it some-hstream-cli hstream --port 6570 sql

    向 stream 中写入数据

    输入并运行以下所有 INSERT 语句，然后关注我们之前创建的 CLI 窗口。

    不出意外的话，你将看到以下的结果。

    1. {"temperature":22,"humidity":80}
    2. {"temperature":31,"humidity":76}
    3. {"temperature":27,"humidity":82}