云边一体的 EMQ 物联网解决方案

wget https://www.emqx.com/zh/downloads/enterprise/v4.4.19/emqx-ee-4.4.19-otp24.3.4.2-1-amzn2-amd64.rpm

yum install emqx-ee-4.4.19-otp24.3.4.2-1-amzn2-amd64.rpm -y

sudo systemctl start emqx

version: "3.5"

services:
  hserver:
    image: hstreamdb/hstream:latest
    depends_on:
      - zookeeper
      - hstore
    ports:
      - "127.0.0.1:6570:6570"
    expose:
      - 6570
    networks:
      - hstream-quickstart
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
      - /tmp:/tmp
      - data_store:/data/store
    command:
      - bash
      - "-c"
      - |
        set -e
        /usr/local/script/wait-for-storage.sh hstore 6440 zookeeper 2181 600 \
        /usr/local/bin/hstream-server \
        --bind-address 0.0.0.0 --port 6570 \
        --internal-port 6571 \
        --server-id 100 \
        --seed-nodes "$$(hostname -I | awk '{print $$1}'):6571" \
        --advertised-address $$(hostname -I | awk '{print $$1}') \
        --metastore-uri zk://zookeeper:2181 \
        --store-config /data/store/logdevice.conf \
        --store-admin-host hstore --store-admin-port 6440 \
        --store-log-level warning \
        --io-tasks-path /tmp/io/tasks \
        --io-tasks-network hstream-quickstart

  hstore:
    image: hstreamdb/hstream:latest
    networks:
      - hstream-quickstart
    volumes:
      - data_store:/data/store
    command:
      - bash
      - "-c"
      - |
        set -ex
        # N.B. "enable-dscp-reflection=false" is required for linux kernel which
        # doesn't support dscp reflection, e.g. centos7.
        /usr/local/bin/ld-dev-cluster --root /data/store \
        --use-tcp --tcp-host $$(hostname -I | awk '{print $$1}') \
        --user-admin-port 6440 \
        --param enable-dscp-reflection=false \
        --no-interactive
  zookeeper:
    image: zookeeper
    expose:
      - 2181
    networks:
      - hstream-quickstart
    volumes:
      - data_zk_data:/data
      - data_zk_datalog:/datalog
networks:
  hstream-quickstart:
    name: hstream-quickstart

volumes:
  data_store:
    name: quickstart_data_store
  data_zk_data:
    name: quickstart_data_zk_data
  data_zk_datalog:
    name: quickstart_data_zk_datalog

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

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

CREATE STREAM test;
SELECT * FROM test WHERE humidity > 70 EMIT CHANGES;

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

INSERT INTO test (temperature, humidity) VALUES (22, 80);
INSERT INTO test (temperature, humidity) VALUES (15, 20);
INSERT INTO test (temperature, humidity) VALUES (31, 76);

> SELECT * FROM test WHERE humidity > 70 EMIT CHANGES;

{"humidity":{"$numberLong":"80"},"temperature":{"$numberLong":"22"}}
{"humidity":{"$numberLong":"76"},"temperature":{"$numberLong":"31"}}

docker pull emqx/neuron:latest  

docker run -d --name neuron -p 7000:7000 --privileged=true --restart=always emqx/neuron:latest

curl -LO https://www.emqx.com/en/downloads/MQTTX/v1.9.3/mqttx-cli-linux-x64 
sudo install ./mqttx-cli-linux-x64 /usr/local/bin/mqttx

mqttx simulate -sc tesla -c 100 -t 'Topic'

[7/11/2023] [5:25:24 PM] ›  Start simulation publishing, scenario: tesla, connections: 100, req interval: 10ms, message interval: 1000ms  success   [100/100] - Connected 
[7/11/2023] [5:25:25 PM] › Created 100 connections in 1.075s 
[7/11/2023] [5:25:40 PM] ›  Published total: 1500, message rate: 100/s

{
  "car_id": "Z5HCY53YSYLP71542",
  "display_name": "Celestine's Tesla",
  "model": "X",
  "trim_badging": "officia",
  "exterior_color": "orange",
  "wheel_type": "veritatis",
  "spoiler_type": "adipisci",
  "geofence": "Vaughntown",
  "state": "asleep",
  "since": "2023-07-11T11:53:13.912Z",
  "healthy": true,
  "version": "1.6.5",
  "update_available": true,
  "update_version": "9.1.4",
  "latitude": "4.7053",
  "longitude": "-146.0241",
  "shift_state": "D",
  "power": 5124,
  "speed": 69,
  "heading": 11,
  "elevation": 3710,
  "locked": false,
  "sentry_mode": true,
  "windows_open": true,
  "doors_open": true,
  "trunk_open": true,
  "frunk_open": true,
  "is_user_present": false,
  "is_climate_on": true,
  "inside_temp": -1.8,
  "outside_temp": 16,
  "is_preconditioning": true,
  "odometer": 453885,
  "est_battery_range_km": 433.2,
  "rated_battery_range_km": 979.1,
  "ideal_battery_range_km": 904.4,
  "battery_level": 52,
  "usable_battery_level": 34,
  "plugged_in": true,
  "charge_energy_added": 27.41,
  "charge_limit_soc": 24,
  "charge_port_door_open": true,
  "charger_actual_current": 71.05,
  "charger_power": 17,
  "charger_voltage": 223,
  "charge_current_request": 24,
  "charge_current_request_max": 34,
  "scheduled_charging_start_time": "2026-01-09T05:51:00.807Z",
  "time_to_full_charge": 2.25,
  "tpms_pressure_fl": 3,
  "tpms_pressure_fr": 2.2,
  "tpms_pressure_rl": 3.3,
  "tpms_pressure_rr": 2.9,
  "timestamp": 1689095696286
}