ステップ1: JWT トークンを取得

まず、ログインして認証トークンを取得します。

import requests

API_BASE = "https://localhost:8443"

# ログインしてトークン取得
response = requests.post(
    f"{API_BASE}/login",
    json={"username": "admin", "password": "admin"},
    verify=False  # 自己署名証明書の場合
)
token = response.json()["access_token"]
headers = {"Authorization": f"Bearer {token}"}

ステップ2: 条件でフローを検索

Source IP と Multicast IP を指定してフローを検索します。

# フロー検索
params = {
    "source_addr_a": "192.168.10.101",
    "multicast_addr_a": "239.100.1.10"
}
response = requests.get(
    f"{API_BASE}/api/flows",
    headers=headers,
    params=params,
    verify=False
)
flows = response.json()
if not flows:
    print("フローが見つかりません")
    exit(1)

flow_id = flows[0]["flow_id"]
print(f"対象フロー: {flow_id}")

ステップ3: PATCH で部分更新

取得した flow_id を使って、必要なフィールドだけを更新します。

# フロー情報を部分更新
update_data = {
    "alias1": "Studio A Main Camera (Updated)",
    "user_field7": "Operator: Sarah Martinez",
    "user_field8": "Emergency: ext.1234"
}
response = requests.patch(
    f"{API_BASE}/api/flows/{flow_id}",
    headers=headers,
    json=update_data,
    verify=False
)

if response.status_code == 200:
    print("更新成功")
elif response.status_code == 423:
    print("エラー: フローがロックされています")
else:
    print(f"エラー: {response.status_code} - {response.text}")

ステップ4: 更新内容を確認

最後に GET で取得し、更新が反映されているか確認します。

# 更新後のフロー情報を取得
response = requests.get(
    f"{API_BASE}/api/flows/{flow_id}",
    headers=headers,
    verify=False
)
flow = response.json()
print(f"alias1: {flow['alias1']}")
print(f"user_field7: {flow['user_field7']}")
print(f"user_field8: {flow['user_field8']}")

Node.js での MQTT 購読例

const mqtt = require('mqtt');

// MQTT ブローカーに接続
const client = mqtt.connect('mqtt://localhost:1883', {
  username: 'mmam',
  password: 'your-mqtt-password'
});

client.on('connect', () => {
  console.log('MQTT接続成功');

  // フローイベントを購読（作成/更新/削除）
  client.subscribe('mmam/flows/events', (err) => {
    if (!err) console.log('購読開始: mmam/flows/events');
  });
});

client.on('message', (topic, payload) => {
  const event = JSON.parse(payload.toString());

  if (topic === 'mmam/flows/events') {
    console.log(`フローイベント: ${event.event}`);
    console.log(`  flow_id: ${event.flow_id}`);
    console.log(`  display_name: ${event.flow?.display_name}`);

    // Slackへ通知する例
    if (event.event === 'created') {
      notifySlack(`新しいフローが作成されました: ${event.flow?.display_name}`);
    }
  }
});

Python での MQTT 購読例

import paho.mqtt.client as mqtt
import json

def on_connect(client, userdata, flags, rc):
    print(f"MQTT接続: {rc}")
    client.subscribe("mmam/flows/events")

def on_message(client, userdata, msg):
    event = json.loads(msg.payload.decode())

    if msg.topic == "mmam/flows/events":
        print(f"フローイベント: {event['event']}")
        print(f"  flow_id: {event['flow_id']}")
        # データベースに記録する例
        log_to_database(event)

client = mqtt.Client()
client.username_pw_set("mmam", "your-mqtt-password")
client.on_connect = on_connect
client.on_message = on_message
client.connect("localhost", 1883, 60)
client.loop_forever()