id

import eventlet

from flask import Flask, send_from_directory
from flask_socketio import SocketIO, emit
from paho.mqtt.client import CallbackAPIVersion
import paho.mqtt.client as mqtt

eventlet.monkey_patch()

app = Flask(__name__)

id

apiVersion: apps.emqx.io/v2beta1
kind: EMQX
metadata:
  name: emqx
spec:
  image: emqx/emqx-enterprise:5.6.0
  config:
    data: |
      log.console.level = debug
      connectors {

id

#!/usr/bin/env bash

set -xeuo pipefail

apt update && apt install -yyq unixodbc-dev odbcinst wget unixodbc libreadline8
wget -nc 'https://sfc-repo.snowflakecomputing.com/odbc/linux/3.3.2/snowflake-odbc-3.3.2.x86_64.deb'
apt install -y ./snowflake-odbc-3.3.2.x86_64.deb

ODBC_INST_LIB=/usr/lib/x86_64-linux-gnu/libodbcinst.so
sed -i -e "s#^ODBCInstLib=.*#ODBCInstLib=$ODBC_INST_LIB#" /usr/lib/snowflake/odbc/lib/simba.snowflake.ini

id

provider "google" {
  project = "<project_id>"
  region  = "europe-central2"
}

variable "project_id" {
  type = string
}

variable "region" {

id

authorization {
  deny_action = ignore
  no_match = deny
  sources = [
    {
      body {
        username = "${username}"
      }
      enable = true
      headers {

id

FROM gcr.io/datadoghq/agent:latest
RUN agent integration install -r -t datadog-emqx==1.0.0

id

const mqtt = require("mqtt");

const url = 'mqtts://127.0.0.1:8883'
const options = {
  clean: true,
  connectTimeout: 1000,
  clientId: 'emqx_test',
  username: 'emqx_test',
  password: 'emqx_test',
  rejectUnauthorized: false,

id

#!/usr/bin/env python3
import asyncio
import random
import string
import json
import paho.mqtt.client as mqtt

broker = 'localhost'
port = 1883
alhabet = string.ascii_lowercase+string.digits

id

import * as crypto from 'crypto';

function encryptToken(token: string, password: string): string {
  const iv = crypto.randomBytes(16);
  let cipher = crypto.createCipheriv('aes-256-cbc', Buffer.from(password), iv);
  let encrypted = cipher.update(token);
  encrypted = Buffer.concat([encrypted, cipher.final()]);
  return `${iv.toString('hex')}:${encrypted.toString('hex')}`;
}

id

EMQX e4.4.17 --> Prometheus --> CloudWatch

Tested on a stock Ubuntu 22.04 AMI.

EMQX

sudo apt update
sudo apt install ./emqx-ee-4.4.17-otp24.3.4.2-1-ubuntu22.04-amd64.deb
sudo systemctl restart emqx
curl -f "127.0.0.1:8081/api/v4/emqx_prometheus?type=prometheus"