MQTT データ フロー エンドポイントを構成する

1. 操作エクスペリエンスで、[データ フロー エンドポイント] を選択します。

2. 既定のエンドポイントを選択して、設定を表示または編集します。

   

az iot ops データフロー エンドポイント apply コマンドを使用して、既定の MQTT ブローカー データ フロー エンドポイントを作成または変更します。

az iot ops dataflow endpoint apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --name default --config-file <ConfigFilePathAndName>

--config-file パラメーターは、リソース プロパティを含む JSON 構成ファイルのパスとファイル名です。

この例では、ユーザーのホーム ディレクトリに格納されている次のコンテンツを含む default-mqtt-endpoint.json という名前の構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "host": "aio-broker:18883",
        "authentication": {
            "method": "ServiceAccountToken",
            "serviceAccountTokenSettings": {
                "audience": "aio-internal"
            }
        },
        "tls": {
            "mode": "Enabled",
            "trustedCaCertificateConfigMapRef": "azure-iot-operations-aio-ca-trust-bundle"
        }
    }
}

既定の MQTT ブローカー データ フロー エンドポイントを作成または更新するコマンドの例を次に示します。

az iot ops dataflow endpoint apply --resource-group myResourceGroup --instance myAioInstance --name default --config-file ~/default-mqtt-endpoint.json

既定のエンドポイントを編集するには、次の内容を含む Bicep .bicep ファイルを作成します。 必要に応じて設定を更新し、<AIO_INSTANCE_NAME> などのプレースホルダーの値を独自の値に置き換えます。

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource defaultMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: 'default'
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: 'aio-broker:18883'
      authentication: {
        method: 'ServiceAccountToken'
        serviceAccountTokenSettings: {
          audience: 'aio-internal'
        }
      }
      tls: {
        mode: 'Enabled'
        trustedCaCertificateConfigMapRef: 'azure-iot-operations-aio-ca-trust-bundle'
      }
    }
  }
}

次に、Azure CLI を使用してデプロイします。

az deployment group create --resource-group <RESOURCE_GROUP> --template-file <FILE>.bicep

Kubernetes クラスターでは、既定の MQTT ブローカー エンドポイント設定を表示できます。 設定を表示するには、次のコマンドを使用します。

kubectl get dataflowendpoint default -n azure-iot-operations -o yaml

1. 操作エクスペリエンスで、[データ フロー エンドポイント] を選択します。

2. [Create new data flow endpoint]\(データ フロー エンドポイントの新規作成\) で、[Azure IoT Operations ローカル MQTT]>[新規] を選びます。

   

   エンドポイントに関する次の設定を入力します。

   設定	説明
   名前	データ フロー エンドポイントの名前。
   ホスト	MQTT ブローカーのホスト名とポート。 <hostname>:<port> の形式を使用します
   認証方法	認証に使用する方式。 "サービス アカウント トークン" または "X509 証明書" を選択します
   サービス対象ユーザー	サービス アカウント トークンの対象ユーザー。 "サービス アカウント トークン" を使用する場合に必要です。
   X509 クライアント証明書	認証に使用する X.509 クライアント証明書。 "X509 証明書" を使う場合に必要です。 業界標準の複数行の X509 証明書をアップロードすると、デバイスの認証管理、セキュリティ、柔軟性が向上します。
   X509 クライアント キー	X.509 クライアント証明書に対応する秘密キー。 "X509 証明書" を使う場合に必要です。
   X509 中間証明書	X.509 クライアント証明書チェーンの中間証明書。 "X509 証明書" を使う場合に必要です。

作成または置換

az iot ops データフロー エンドポイント create fabric-onelake コマンドを使用して、ローカル MQTT ブローカー データ フロー エンドポイントを作成または置き換えます。

az iot ops dataflow endpoint create local-mqtt --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --port <Port> --host <Host>

このコマンドは、既定の設定でローカル MQTT ブローカー エンドポイントを作成します。 必要に応じて、追加のオプションを指定できます。

local-mqtt-endpointという名前のローカル MQTT ブローカー データ フロー エンドポイントを作成または置き換えるコマンドの例を次に示します。

az iot ops dataflow endpoint create local-mqtt --resource-group myResourceGroup --instance myAioInstance --name local-mqtt-endpoint --port 1883 --host aio-broker --auth-type ServiceAccountToken --audience aio-internal

作成または変更

az iot ops dataflow endpoint apply コマンドを使用して、ローカル MQTT ブローカーのデータ フロー エンドポイントを作成または変更します。

az iot ops dataflow endpoint apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --config-file <ConfigFilePathAndName>

--config-file パラメーターは、リソース プロパティを含む JSON 構成ファイルのパスとファイル名です。

この例では、ユーザーのホーム ディレクトリに格納されている次のコンテンツを含む local-mqtt-endpoint.json という名前の構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "host": "aio-broker:1883",
        "authentication": {
            "method": "ServiceAccountToken",
            "serviceAccountTokenSettings": {
                "audience": "aio-internal"
            }
        },
        "tls": {
            "mode": "Enabled",
            "trustedCaCertificateConfigMapRef": "azure-iot-operations-aio-ca-trust-bundle"
        }
    }
}

local-mqtt-endpointという名前のローカル MQTT ブローカー データ フロー エンドポイントを作成または更新するコマンドの例を次に示します。

az iot ops dataflow endpoint apply --resource-group myResourceGroup --instance myAioInstance --name local-mqtt-endpoint --config-file ~/local-mqtt-endpoint.json

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'
param endpointName string = '<ENDPOINT_NAME>'
param mqttBrokerHostname string = '<HOSTNAME>:<PORT>'
param trustedCA string = '<TRUST_BUNDLE>'
param serviceAccountAudience string = '<SA_AUDIENCE>'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource MqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: mqttBrokerHostname
      authentication: {
        method: 'ServiceAccountToken'
        serviceAccountTokenSettings: {
          audience: serviceAccountAudience
        }
      }
      tls: {
        mode: 'Enabled'
        trustedCaCertificateConfigMapRef: trustedCA
      }
    }
  }
}

apiVersion: connectivity.iotoperations.azure.com/v1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: Mqtt
  mqttSettings:
    host: "<HOSTNAME>:<PORT>"
    tls:
      mode: Enabled
      trustedCaCertificateConfigMapRef: <TRUST_BUNDLE>
    authentication:
      method: ServiceAccountToken
      serviceAccountTokenSettings:
        audience: <SA_AUDIENCE>

1. 操作エクスペリエンスで、[データ フロー エンドポイント] タブを選択します。

2. [データ フロー エンドポイントの新規作成] で、[Azure Event Grid MQTT]>[新規] を選びます。

   

   エンドポイントに関する次の設定を入力します。

   設定	説明
   名前	データ フロー エンドポイントの名前。
   ホスト	Event Grid MQTT ブローカーのホスト名とポート。 <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883 の形式を使用します
   認証方法	認証に使用する方式。 [システム割り当てマネージド ID] または [ユーザー割り当てマネージド ID] を選択することをお勧めします。

3. [適用] を選択してエンドポイントをプロビジョニングします。

作成または置換

az iot ops データフロー エンドポイント create eventgrid コマンドを使用して、Azure Event Grid MQTT データ フロー エンドポイントを作成または置換します。

az iot ops dataflow endpoint create eventgrid --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --host <Namespace>.<Region>-1.ts.eventgrid.azure.net --port 9092

このコマンドは、既定の設定とシステム割り当てマネージド ID 認証を使用して Event Grid MQTT ブローカー エンドポイントを作成します。 必要に応じて、追加のオプションを指定できます。

event-grid-endpointという名前の Event Grid MQTT ブローカー データ フロー エンドポイントを作成または置換するコマンドの例を次に示します。

az iot ops dataflow endpoint create eventgrid --resource-group myResourceGroup --instance myAioInstance --name event-grid-endpoint --host mynamespace.eastus-1.ts.eventgrid.azure.net --port 9092

作成または変更

az iot ops データフロー エンドポイント apply コマンドを使用して、Azure Event Grid MQTT ブローカー のデータ フロー エンドポイントを作成または変更します。

az iot ops dataflow endpoint apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --config-file <ConfigFilePathAndName>

--config-file パラメーターは、リソース プロパティを含む JSON 構成ファイルのパスとファイル名です。

この例では、ユーザーのホーム ディレクトリに格納されている次のコンテンツを含む event-grid-endpoint.json という名前の構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "host": "mynamespace.eastus-1.ts.eventgrid.azure.net:9092",
        "authentication": {
            "method": "SystemAssignedManagedIdentity",
            "systemAssignedManagedIdentitySettings": {}
        },
        "tls": {
            "mode": "Enabled"
        }
    }
}

event-grid-endpointという名前の Event Grid MQTT ブローカー データ フロー エンドポイントを作成または更新するコマンドの例を次に示します。

az iot ops dataflow endpoint apply --resource-group myResourceGroup --instance myAioInstance --name event-grid-endpoint --config-file ~/event-grid-endpoint.json

次の内容を含む Bicep .bicep ファイルを作成します。

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'
param endpointName string = '<ENDPOINT_NAME>'
param eventGridHostName string = '<NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource remoteMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: eventGridHostName
      authentication: {
        // See available authentication methods section for method types
        // method: <METHOD_TYPE>
      }
      tls: {
        mode: 'Enabled'
      }
    }
  }
}

次に、Azure CLI を使用してデプロイします。

az deployment group create --resource-group <RESOURCE_GROUP> --template-file <FILE>.bicep

次の内容を含む Kubernetes マニフェスト .yaml ファイルを作成します。

apiVersion: connectivity.iotoperations.azure.com/v1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: Mqtt
  mqttSettings:
    host: <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883
    authentication:
      # See available authentication methods section for method types
      # method: <METHOD_TYPE>
    tls:
      mode: Enabled

次に、このマニフェスト ファイルを Kubernetes クラスターに適用します。

kubectl apply -f <FILE>.yaml

1. 操作エクスペリエンスで、[データ フロー エンドポイント] タブを選択します。

2. [データ フロー エンドポイントの新規作成] で、[カスタム MQTT ブローカー]>[新規] を選びます。

   

3. エンドポイントに関する次の設定を入力します。

   設定	説明
   名前	データ フロー エンドポイントの名前
   ホスト	<hostname>.<port> 形式での MQTT ブローカー エンドポイントのホスト名。
   認証方法	認証に使用する方式。 "サービス アカウント トークン" または "X509 証明書" を選択します。
   サービス対象ユーザー	サービス アカウント トークンの対象ユーザー。 "サービス アカウント トークン" を使用する場合に必要です。
   X509 クライアント証明書	認証に使用する X.509 クライアント証明書。 "X509 証明書" を使う場合に必要です。 業界標準の複数行の X509 証明書をアップロードすると、デバイスの認証管理、セキュリティ、柔軟性が向上します。
   X509 クライアント キー	X.509 クライアント証明書に対応する秘密キー。 "X509 証明書" を使う場合に必要です。
   X509 中間証明書	X.509 クライアント証明書チェーンの中間証明書。 "X509 証明書" を使う場合に必要です。

4. [適用] を選択してエンドポイントをプロビジョニングします。

作成または置換

az iot ops データフロー エンドポイント create custom-mqtt コマンドを使用して、カスタム MQTT ブローカー データ フロー エンドポイントを作成または置換します。

az iot ops dataflow endpoint create custom-mqtt --resource-group <ResourceGroupName> --instance <AioInstanceName>  --name <EndpointName> --host <Host> --port <Port>

このコマンドは、既定の設定とシステム割り当てマネージド ID 認証を使用して、カスタム MQTT ブローカー エンドポイントを作成します。 必要に応じて、追加のオプションを指定できます。

custom-mqtt-endpointという名前のカスタム MQTT ブローカー データ フロー エンドポイントを作成または置換するコマンドの例を次に示します。

az iot ops dataflow endpoint create custom-mqtt --resource-group myResourceGroup --instance myAioInstance --name custom-mqtt-endpoint --host mycustombroker.contoso.com --port 8883

作成または変更

az iot ops データフロー エンドポイント apply コマンドを使用して、カスタム MQTT ブローカー データ フロー エンドポイントを作成または変更します。

az iot ops dataflow endpoint apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --config-file <ConfigFilePathAndName>

--config-file パラメーターは、リソース プロパティを含む JSON 構成ファイルのパスとファイル名です。

この例では、ユーザーのホーム ディレクトリに格納されている次のコンテンツを含む custom-mqtt-endpoint.json という名前の構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "host": "mycustombroker.contoso.com:8883",
        "authentication": {
          "method": "SystemAssignedManagedIdentity",
          "systemAssignedManagedIdentitySettings": {}
        },
        "tls": {
            "mode": "Enabled"
        }
    }
}

custom-mqtt-endpointという名前のカスタム MQTT ブローカー データ フロー エンドポイントを作成または更新するコマンドの例を次に示します。

az iot ops dataflow endpoint apply --resource-group myResourceGroup --instance myAioInstance --name custom-mqtt-endpoint --config-file ~/custom-mqtt-endpoint.json

mqttSettings: {
  authentication: {
    // See available authentication methods section for method types
    // method: <METHOD_TYPE>
  }
  host: '<HOST>:<PORT>'
  tls: {
    mode: 'Enabled' // or 'Disabled'
    trustedCaCertificateConfigMapRef: '<TRUSTED_CA_CERT_CONFIGMAP>'
  }
}

spec:
  endpointType: Mqtt
  mqttSettings:
    host: <HOST>:<PORT>
    authentication:
      # See available authentication methods section for method types
      # method: <METHOD_TYPE>
    tls:
      mode: Enabled # or Disabled
      trustedCaCertificateConfigMapRef: <TRUSTED_CA_CERT_CONFIGMAP>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[システム割り当てマネージド ID] を選択します。

作成または置換

az iot ops dataflow endpoint create コマンドを使用し、--auth-type パラメーターをシステム割り当てマネージド ID 認証のSystemAssignedManagedIdentityに設定します。

az iot ops dataflow endpoint create <Command> --auth-type SystemAssignedManagedIdentity --audience <Audience> --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

az iot ops dataflow endpoint apply コマンドを --config-file パラメーターと共に使用します。

この例では、次の内容を含む構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "host": "mycustombroker.contoso.com:8883",
        "authentication": {
          "method": "SystemAssignedManagedIdentity",
          "systemAssignedManagedIdentitySettings": {}
        },
        "tls": {
            "mode": "Enabled"
        }
    }
}

mqttSettings: {
  authentication: {
    method: 'SystemAssignedManagedIdentity'
    systemAssignedManagedIdentitySettings: {}
  }
}

mqttSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      {}

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[ユーザー割り当てマネージド ID] を選択します。

作成または置換

az iot ops dataflow endpoint create コマンドを使用し、--auth-type パラメーターをユーザー割り当てマネージド ID 認証のUserAssignedManagedIdentityに設定します。

az iot ops dataflow endpoint create <Command> --auth-type UserAssignedManagedIdentity --client-id <ClientId> --tenant-id <TenantId> --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

パラメーターで --config-file を使用する

この例では、次の内容を含む構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "authentication": {
          "method": "UserAssignedManagedIdentity",
          "userAssignedManagedIdentitySettings": {
            "clientId": "<ID>",
            "tenantId": "<ID>",
            // Optional
            "scope": "https://<Scope_Url>"
          }
        }
    }
}

mqttSettings: {
  authentication: {
    method: 'UserAssignedManagedIdentity'
    userAssignedManagedIdentitySettings: {
      clientId: '<ID>'
      tenantId: '<ID>'
      // Optional, defaults to 'https://eventgrid.azure.net/.default'
      // scope: 'https://<SCOPE_URL>' 
    }
  }
}

mqttSettings:
  authentication:
    method: UserAssignedManagedIdentity
    userAssignedManagedIdentitySettings:
      clientId: <ID>
      tenantId: <ID>
      # Optional, defaults to 'https://eventgrid.azure.net/.default'
      # scope: https://<SCOPE_URL>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[サービス アカウント トークン] を選択します。

サービスの対象ユーザーを入力します。

作成または置換

az iot ops dataflow endpoint create コマンドを使用して、--auth-type パラメーターを ServiceAccountToken に設定し、Kubernetes サービス アカウント トークン認証を行います。

az iot ops dataflow endpoint create <Command> --auth-type ServiceAccountToken --audience <Audience> --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

パラメーターで --config-file を使用します。

この例では、次の内容を含む構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "authentication": {
          "method": "ServiceAccountToken",
          "serviceAccountTokenSettings": {
            "audience": "<ServiceAccountAudience>"
          }
        }
    }
}

mqttSettings: {
  authentication: {
    method: 'ServiceAccountToken'
    serviceAccountTokenSettings: {
      audience: '<YOUR_SERVICE_ACCOUNT_AUDIENCE>'
    }
  }
}

mqttSettings:
  authentication:
    method: ServiceAccountToken
    serviceAccountTokenSettings:
      audience: <YOUR_SERVICE_ACCOUNT_AUDIENCE>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[X509 証明書] を選択します。

ここで、[同期されたシークレット名] にシークレットの名前を入力します。 この名前は、データ フロー エンドポイントの設定でシークレットの参照に使われ、Kubernetes クラスターに格納されているシークレットの名前です。

次に、[X509 クライアント証明書]、[X509 クライアント キー]、[X509 中間証明書] で、[参照の追加] を選択して証明書、秘密キー、中間証明書を追加します。 次のページで、Azure Key Vault のシークレットを選択し、Azure Key Vault から追加するか、シークレットを新規作成します。

[新規作成] を選択した場合は、次の設定を入力します。

シークレットの詳細については、「Azure IoT Operations でのシークレットの作成と管理」を参照してください。

作成または置換

az iot ops データフロー エンドポイント作成 コマンドを使用し、--auth-type パラメーターを X509Certificate に設定して x.509 証明書認証を行います。

az iot ops dataflow endpoint create <Command> --auth-type X509Certificate --secret-name <X509SecretName> --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

パラメーターで --config-file を使用します。

この例では、次の内容を含む構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "authentication": {
          "method": "X509Certificate",
          "x509CertificateSettings": {
            "secretRef": "<X509SecretName>"
          }
        }
    }
}

mqttSettings: {
  authentication: {
    method: 'X509Certificate'
      x509CertificateSettings:
        secretRef: '<X509_SECRET_NAME>'
  }
}

mqttSettings:
  authentication:
    method: X509Certificate
    x509CertificateSettings:
      secretRef: <X509_SECRET_NAME>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[なし] を選択します。

作成または置換

匿名認証には、 パラメーターを指定して --no-authコマンドを使用します。

az iot ops dataflow endpoint create <Command> --no-auth --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

パラメーターで --config-file を使用します。

この例では、次の内容を含む構成ファイルを想定しています。

{
    "endpointType": "Mqtt",
    "mqttSettings": {
        "authentication": {
          "method": "Anonymous"
        }
    }
}

mqttSettings: {
  authentication: {
    method: 'Anonymous'
  }
}

mqttSettings:
  authentication:
    method: Anonymous
    anonymousSettings:
      {}

操作エクスペリエンスで、データ フロー エンドポイントの [詳細] タブを選択します。

{
    "mqttSettings": {
        "qos": 1,
        "retain": "Keep",
        "sessionExpirySeconds": 3600,
        "keepAliveSeconds": 60,
        "maxInflightMessages": 100,
        "protocol": "WebSockets",
        "clientIdPrefix": "dataflow",
        "cloudEventAttributes": "Propagate",
        "tls": {
          "mode": "Enabled"
        }
    }
}

// See sections below for explanation of each setting
mqttSettings: {
  qos: 1
  retain: 'Keep'
  sessionExpirySeconds: 3600
  keepAliveSeconds: 60
  maxInflightMessages: 100
  protocol: WebSockets
  clientIdPrefix: 'dataflow'
  cloudEventAttributes : 'Propagate' // or 'CreateOrRemap'
}

# See sections below for explanation of each setting
mqttSettings:
  qos: 1
  retain: Keep
  sessionExpirySeconds: 3600
  keepAliveSeconds: 60
  maxInflightMessages: 100
  protocol: WebSockets
  clientIdPrefix: dataflow
  cloudEventAttributes : Propagate # or CreateOrRemap

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細] タブを選択し、[TLS モードが有効] の横にあるチェックボックスを使用します。

{
    "mqttSettings": {
        "tls": {
          "mode": "Enabled"
        }
    }
}

mqttSettings: {
  tls: {
    mode: 'Enabled' // or 'Disabled'
  }
}

mqttSettings:
  tls:
    mode: Enabled # or Disabled

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細] タブを選択し、[信頼された CA 証明書構成マップ] フィールドを使用して、信頼された CA 証明書を含む ConfigMap を指定します。

mqttSettings: {
  tls: {
    trustedCaCertificateConfigMapRef: '<YOUR_CA_CERTIFICATE>'
  }
}

{
    "mqttSettings": {
        "tls": {
          "trustedCaCertificateConfigMapRef": "<YOUR_CA_CERTIFICATE>"
        }
    }
}

mqttSettings:
  tls:
    trustedCaCertificateConfigMapRef: <YOUR_CA_CERTIFICATE>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[クライアント ID プレフィックス] フィールドを使用してプレフィクスを指定します。

{
    "mqttSettings": {
        "clientIdPrefix": "<YOUR_PREFIX>"
    }
}

mqttSettings: {
  clientIdPrefix: '<YOUR_PREFIX>'
}

mqttSettings:
  clientIdPrefix: <YOUR_PREFIX>

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[サービスの品質 (QoS)] フィールドを使用して QoS レベルを指定します。

{
    "mqttSettings": {
        "qos": 1
    }
}

mqttSettings: {
  qos: 1 // Or 0
}

mqttSettings:
  qos: 1 # Or 0

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[保持] フィールドを使用して保持設定を指定します。

{
    "mqttSettings": {
        "retain": "Keep"
    }
}

mqttSettings: {
  retain: Keep // or Never
}

mqttSettings:
  retain: Keep # or Never

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[セッションの有効期間] フィールドを使用してセッションの有効期間間隔を指定します。

{
    "mqttSettings": {
        "sessionExpirySeconds": 600
    }
}

mqttSettings: {
  sessionExpirySeconds: 600
}

mqttSettings:
  sessionExpirySeconds: 600

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[プロトコル] フィールドを使用してプロトコルを指定します。

{
    "mqttSettings": {
        "protocol": "WebSockets"
    }
}

mqttSettings: {
  protocol: 'WebSockets'
}

mqttSettings:
  protocol: WebSockets

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[フライト中のメッセージの最大数] フィールドを使用して配信中のメッセージの最大数を指定します。

{
    "mqttSettings": {
        "maxInflightMessages": 100
    }
}

mqttSettings: {
  maxInflightMessages: 100
}

mqttSettings:
  maxInflightMessages: 100

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細設定] タブを選択し、[キープ アライブ] フィールドを使用してキープ アライブ間隔を指定します。

{
    "mqttSettings": {
        "keepAliveSeconds": 60
    }
}

mqttSettings: {
  keepAliveSeconds: 60
}

mqttSettings:
  keepAliveSeconds: 60

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[詳細] タブを選択し、[クラウド イベント属性] フィールドを使用して CloudEvents 設定を指定します。

{
    "mqttSettings": {
        "cloudEventAttributes": "Propagate"
    }
}

mqttSettings: {
  cloudEventAttributes : 'Propagate' // or 'CreateOrRemap'
}

mqttSettings:
  cloudEventAttributes : Propagate # or CreateOrRemap