Microsoft Fabric リアルタイム インテリジェンスのデータフロー エンドポイントを構成する

このメソッドでは、Azure IoT Operations インスタンスのマネージド ID を使用して、イベント ストリームで認証します。 システム割り当てマネージド ID 認証方法を使用して、データ フロー エンドポイントを構成します。

1. 接続の詳細は、Fabric ポータルのイベント ストリームの [ ソース ] セクションにあります。

2. カスタム エンドポイントの詳細パネルで、 Kafka プロトコルを選択します。

3. [Entra ID Authentication]\(Entra ID 認証\) セクションを選択して、接続の詳細を表示します。

4. ブートストラップ サーバー、トピック名、接続文字列の主キーの値の詳細をコピーします。 これらの値を使用して、データ フロー エンドポイントを構成します。

   

   設定	説明
   ブートストラップ サーバー	ブートストラップ サーバー アドレスは、データ フロー エンドポイントのホスト名プロパティに使用されます。
   トピック名	イベント ハブ名は Kafka トピックとして使用され、 es_aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb の形式です。

1. 接続の詳細は、Fabric ポータルのイベント ストリームの [ ソース ] セクションにあります。

2. カスタム エンドポイントの詳細パネルで、 Kafka プロトコルを選択します。

3. [SAS キー認証] セクションを選択して、接続の詳細を表示します。

4. ブートストラップ サーバー、トピック名、接続文字列の主キーの値の詳細をコピーします。 これらの値を使用して、データ フロー エンドポイントを構成します。

   

   設定	説明
   ブートストラップ サーバー	ブートストラップ サーバー アドレスは、データ フロー エンドポイントのホスト名プロパティに使用されます。
   トピック名	イベント ハブ名は Kafka トピックとして使用され、 es_aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb の形式です。
   接続文字列 - 主キー	主キーを含む接続文字列。

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

2. [新しいデータ フロー エンドポイントの作成] で、Microsoft Fabric Real-Time Intelligence>New を選択します。

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

   

   設定	説明
   名前	データ フロー エンドポイントの名前。
   Host	*.servicebus.windows.net:9093形式のイベント ストリーム カスタム エンドポイントのホスト名。 以前にメモしておいたブートストラップ サーバー アドレスを使用します。
   認証方法	認証に使用する方式。 Entra ID の場合、 システム割り当てマネージド ID、ユーザー割り当てマネージド ID または SASL を選択します。

   SASL 認証方法を選択する場合は、次の設定も入力する必要があります。

   設定	説明
   SASL の種類	[ プレーン] を選択します。
   同期されたシークレット名	同期されたシークレットの名前を入力します。 この名前の Kubernetes シークレットがクラスターに作成されます。

   [ 参照の追加] を選択して新規を作成するか、ユーザー名とパスワードの参照に既存の Key Vault 参照を選択します。

   トークン シークレットのユーザー名参照の場合、シークレット値は、環境変数参照ではなく、リテラル文字列$ConnectionString正確に指定する必要があります。

   

   トークン シークレットのパスワード参照の場合、シークレット値は、イベント ストリーム カスタム エンドポイントの主キーを持つ接続文字列である必要があります。

   

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

作成または置換

az iot ops dataflow endpoint create fabric-onelake コマンドを使用して、Microsoft Fabric Real-Time Intelligence データ フロー エンドポイントを作成または置換します。

az iot ops dataflow endpoint create fabric-realtime --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName> --host "<BootstrapServerAddress>"

fabric-realtime-endpointという名前の Microsoft Fabric Real-Time Intelligence データ フロー エンドポイントを作成または置換するコマンドの例を次に示します。

az iot ops dataflow endpoint create fabric-realtime --resource-group myResourceGroup --instance myAioInstance --name fabric-realtime-endpoint --host "fabricrealtime.servicebus.windows.net:9093"

作成または変更

az iot ops dataflow endpoint apply コマンドを使用して、Microsoft Fabric Real-Time Intelligence データ フロー エンドポイントを作成または変更します。

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

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

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

{
  "endpointType": "FabricRealTimeIntelligence",
  "fabricRealTimeIntelligenceSettings": {
    "authentication": {
      "method": "Sasl",
      "saslSettings": {
        "saslType": "Plain",
        "secretRef": "<SecretName>"
      }
    },
    "host": "<BootstrapServerAddress>",
    "topic": "<TopicName>",
    "names": {
      "workspaceName": "<WorkspaceName>",
      "eventStreamName": "<EventStreamName>"
    }
  }
}

fabric-realtime-endpointという名前の新しい Microsoft Fabric Real-Time Intelligence データ フロー エンドポイントを作成するコマンドの例を次に示します。

az iot ops dataflow endpoint apply --resource-group myResourceGroupName --instance myAioInstanceName --name fabric-realtime-endpoint --config-file ~/fabric-realtime-endpoint.json

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

kafkaSettings: {
  authentication: {
    method: 'Sasl' // Or ScramSha256, ScramSha512
    saslSettings: {
      saslType: 'Plain' // Or ScramSha256, ScramSha512
      secretRef: '<SECRET_NAME>'
    }
  }
}

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

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

kubectl create secret generic sasl-secret -n azure-iot-operations \
  --from-literal=token='<YOUR_SASL_TOKEN>'

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

kafkaSettings:
  authentication:
    method: Sasl
    saslSettings:
      saslType: Plain # Or ScramSha256, ScramSha512
      secretRef: <SECRET_NAME>

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

kubectl apply -f <FILE>.yaml

操作エクスペリエンスのデータ フロー エンドポイント設定ページで、[基本] タブを選択し、[認証方法]>[システム割り当てマネージド 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": "Kafka",
    "kafkaSettings": {
        "host": "fabricrealtime.servicebus.windows.net:9093",
        "authentication": {
            "method": "SystemAssignedManagedIdentity",
            "systemAssignedManagedIdentitySettings": {}
        },
        "tls": {
            "mode": "Enabled"
        }
    }
}

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

kafkaSettings:
  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": "Kafka",
    "kafkaSettings": {
        "authentication": {
          "method": "UserAssignedManagedIdentity",
          "userAssignedManagedIdentitySettings": {
            "clientId": "<ID>",
            "tenantId": "<ID>",
            // Optional
            "scope": "https://<Scope_Url>"
          }
        }
    }
}

kafkaSettings: {
  authentication: {
    method: 'UserAssignedManagedIdentity'
    UserAssignedManagedIdentitySettings: {
      clientId: '<CLIENT_ID>'
      tenantId: '<TENANT_ID>'
      // Optional
      // scope: 'https://<SCOPE_URL>'
    }
  }
  ...
}

kafkaSettings:
  authentication:
    method: UserAssignedManagedIdentity
    userAssignedManagedIdentitySettings:
      clientId: <CLIENT_ID>
      tenantId: <TENANT_ID>
      # Optional
      # scope: https://<SCOPE_URL>

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

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

作成または置換

az iot ops dataflow endpoint create コマンドを使用し、--auth-type パラメーターを SASL 認証用にSaslに設定します。

az iot ops dataflow endpoint create <Command> --auth-type Sasl --sasl-type <SaslType> --secret-name <SecretName> --resource-group <ResourceGroupName> --instance <AioInstanceName> --name <EndpointName>

作成または変更

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

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

{
    "endpointType": "Kafka",
    "kafkaSettings": {
        "authentication": {
          "method": "Sasl",
          "saslSettings": {
            "saslType": "<SaslType>",
            "secretRef": "<SecretName>"
          }
        }
    }
}

kafkaSettings: {
  authentication: {
    method: 'Sasl' // Or ScramSha256, ScramSha512
    saslSettings: {
      saslType: 'Plain' // Or ScramSha256, ScramSha512
      secretRef: '<SECRET_NAME>'
    }
  }
}

kubectl create secret generic sasl-secret -n azure-iot-operations \
  --from-literal=token='<YOUR_SASL_TOKEN>'

kafkaSettings:
  authentication:
    method: Sasl
    saslSettings:
      saslType: Plain # Or ScramSha256, ScramSha512
      secretRef: <SECRET_NAME>