from awsiot.greengrasscoreipc.clientv1 import GreengrassCoreIPCClient
from awscrt import mqtt
import json

client = mqtt.Client(
    bootstrap=bootstrap,
    tls_ctx=tls_context
)

def on_message_received(topic, payload):
    message = json.loads(payload)
    print(f"收到: {message}")

client.subscribe(
    topic="sensor/pressure",
    qos=mqtt.QoS.AT_LEAST_ONCE,
    callback=on_message_received
)

# 發送數據
payload = {
    "temperature_c": 25.3,
    "pressure_bar": 2.5,
    "timestamp": 1234567890
}

client.publish(
    topic="sensor/data",
    payload=json.dumps(payload),
    qos=mqtt.QoS.AT_LEAST_ONCE
)

import paho.mqtt.client as mqtt
import ssl
import json

# Google IoT 特定格式
MQTT_BRIDGE_HOSTNAME = "mqtt.googleapis.com"
MQTT_BRIDGE_PORT = 8883
DEVICE_ID = "my-sensor-device"
PROJECT_ID = "my-gcp-project"
REGION = "us-central1"

# 生成 JWT Token
import jwt
import time

token = jwt.encode(
    {
        "iat": int(time.time()),
        "exp": int(time.time()) + 3600,
        "aud": PROJECT_ID
    },
    PRIVATE_KEY,
    algorithm="RS256"
)

client = mqtt.Client(
    client_id=f"projects/{PROJECT_ID}/locations/{REGION}/registries/my-registry/devices/{DEVICE_ID}"
)
client.username_pw_set("unused", token)
client.tls_set(ca_certs=CA_CERTS)
client.connect(MQTT_BRIDGE_HOSTNAME, MQTT_BRIDGE_PORT, 60)

payload = {
    "temperature_c": 25.3,
    "pressure_bar": 2.5
}

client.publish(
    f"devices/{DEVICE_ID}/events",
    json.dumps(payload),
    qos=1
)

from azure.iot.device import IoTHubDeviceClient
import json

# Azure 最簡單方式：連接字串
CONN_STR = "HostName=my-hub.azure-devices.net;DeviceId=my-sensor;SharedAccessKey=..."

client = IoTHubDeviceClient.create_from_connection_string(CONN_STR)

# 連接
client.connect()

# 定義訊息回調
def message_handler(message):
    print(f"訊息: {message.data}")

# 設置消息接收
client.on_message_received = message_handler

# 發送遙測數據
msg = {
    "temperature_c": 25.3,
    "pressure_bar": 2.5,
    "timestamp": 1234567890
}

client.send_message(json.dumps(msg))