[アップデート]AWS IoT Coreにデバイスとの接続を切断できるDeleteConnection APIが追加されました

deleteconnection-api-aws/
├── scripts/
│   ├── mqtt_client_aws.py          # MQTTクライアント（メイン）
│   └── delete_connection.py        # DeleteConnection API実行スクリプト
├── certs/
│   ├── AmazonRootCA1.pem          # ルート証明書
│   ├── device.pem.crt             # デバイス証明書
│   └── device.pem.key             # 秘密鍵
└── config.json                     # 設定ファイル

pip install awsiotsdk

import time
import json
from awscrt import mqtt
from awsiot import mqtt_connection_builder

class DeviceClient:
    def __init__(self):
        # 設定値（実際の値に置き換えてください）
        self.endpoint = "your-endpoint.iot.ap-northeast-1.amazonaws.com"
        self.client_id = "test-device-001"
        self.cert_path = "../certs/device.pem.crt"
        self.key_path = "../certs/device.pem.key"
        self.ca_path = "../certs/AmazonRootCA1.pem"
        self.mqtt_connection = None
        self.is_connected = False

    def on_connection_interrupted(self, connection, error, **kwargs):
        """接続が中断された時のコールバック"""
        print(f"\n⚠️  接続が中断されました: {error}")
        self.is_connected = False

    def on_connection_closed(self, connection, **kwargs):
        """接続が閉じられた時のコールバック"""
        print(f"\n🔌 接続が閉じられました")
        self.is_connected = False

    def connect(self):
        """AWS IoT Coreに接続"""
        print(f"🔄 接続中: {self.client_id}")

        # LWT（Last Will and Testament）メッセージの設定
        lwt_message = {
            "client_id": self.client_id,
            "status": "disconnected_unexpectedly",
            "timestamp": int(time.time()),
            "message": "Connection lost without proper disconnect"
        }

        # MQTT接続を作成（LWT付き）
        self.mqtt_connection = mqtt_connection_builder.mtls_from_path(
            endpoint=self.endpoint,
            port=8883,
            cert_filepath=self.cert_path,
            pri_key_filepath=self.key_path,
            ca_filepath=self.ca_path,
            client_id=self.client_id,
            clean_session=False,  # Persistent Session使用
            keep_alive_secs=30,
            will=mqtt.Will(
                topic="device/lwt",
                qos=mqtt.QoS.AT_LEAST_ONCE,
                payload=json.dumps(lwt_message).encode('utf-8'),
                retain=False
            ),
            on_connection_interrupted=self.on_connection_interrupted,
            on_connection_closed=self.on_connection_closed
        )

        print("⚰️  LWT設定済み: device/lwt トピックに異常切断時メッセージを送信")

        # 接続
        connected_future = self.mqtt_connection.connect()
        connected_future.result()
        self.is_connected = True
        print(f"✅ 接続成功！")

    def keep_alive(self, duration=120):
        """接続を維持（DeleteConnection APIテスト用）"""
        print(f"\n⏱️  {duration}秒間接続を維持します（Ctrl+Cで停止）")

        try:
            for i in range(duration):
                # 接続状態をチェック
                if not self.is_connected:
                    print(f"\n❌ 接続が切断されました ({i}秒後)")
                    break

                if i % 30 == 0:
                    # 30秒ごとにハートビート
                    heartbeat = {
                        "client_id": self.client_id,
                        "uptime": i,
                        "timestamp": int(time.time())
                    }
                    try:
                        self.mqtt_connection.publish(
                            topic="device/heartbeat",
                            payload=json.dumps(heartbeat).encode('utf-8'),
                            qos=mqtt.QoS.AT_MOST_ONCE
                        )
                        print(f"💓 ハートビート送信 ({i}秒経過)")
                    except Exception as e:
                        print(f"❌ ハートビート送信失敗: {e}")
                        break

                time.sleep(1)

        except KeyboardInterrupt:
            print("\n🛑 停止")

if __name__ == "__main__":
    client = DeviceClient()
    try:
        client.connect()
        client.keep_alive(120)  # 2分間接続維持
    except Exception as e:
        print(f"❌ エラー: {e}")

python scripts/mqtt_client_aws.py

🔄 接続中: test-device-001
⚰️  LWT設定済み: device/lwt トピックに異常切断時メッセージを送信
✅ 接続成功！

⏱️  120秒間接続を維持します（Ctrl+Cで停止）
💓 ハートビート送信 (0秒経過)
💓 ハートビート送信 (30秒経過)
💓 ハートビート送信 (60秒経過)

aws iot-data delete-connection \
    --client-id "test-device-001" \
    --prevent-will-message \
    --region ap-northeast-1

⚠️  接続が中断されました: AWS_ERROR_MQTT_UNEXPECTED_HANGUP: The connection was closed unexpectedly.
❌ 接続が切断されました (4秒後)
💤 既に切断済み

aws iot-data delete-connection \
    --client-id "test-device-001" \
    --region ap-northeast-1

lwt_message = {
            "client_id": self.client_id,
            "status": "disconnected_unexpectedly",
            "timestamp": int(time.time()),
            "message": "Connection lost without proper disconnect"
        }