Konfigurovat koncové body toku dat pro Microsoft Fabric Real-Time Intelligence

Důležité

Tato stránka obsahuje pokyny ke správě komponent operací Azure IoT pomocí manifestů nasazení Kubernetes, které jsou ve verzi Preview. Tato funkce je poskytována s několika omezeními a neměla by se používat pro produkční úlohy.

Podívejte se na doplňkové podmínky užívání služby Microsoft Azure Preview pro právní podmínky, které se vztahují na funkce Azure, jež jsou ve verzi beta, Preview nebo jinak ještě nejsou obecně dostupné.

Pokud chcete odesílat data do Microsoft Fabric v reálném čase z operací Azure IoT, můžete nakonfigurovat koncový bod toku dat. Tato konfigurace umožňuje zadat cílový koncový bod, metodu ověřování, téma a další nastavení.

Požadavky

• Instance Azure IoT Operations
• Vytvořte pracovní prostor Fabric. Výchozí pracovní prostor není podporovaný.
• Vytvoření streamu událostí
• Přidejte vlastní koncový bod jako zdroj

Poznámka:

Event Stream podporuje více vstupních zdrojů včetně Azure Event Hubs. Pokud máte existující tok dat do služby Azure Event Hubs, můžete ho přenést do Fabricu, jak je uvedeno v Rychlém startu. V tomto článku se dozvíte, jak proudí data v reálném čase přímo do Microsoft Fabric bez jakéhokoli dalšího přesměrování.

Získání podrobností o připojení k vlastnímu koncovému bodu

Načtěte podrobnosti připojení kompatibilní s Kafkou pro uživatelsky definovaný koncový bod. Podrobnosti o připojení se používají ke konfiguraci koncového bodu toku dat v operacích Azure IoT.

Ověřování Entra ID

Tato metoda používá spravovanou identitu instance operace Azure IoT k ověření pomocí streamu událostí. Ke konfiguraci koncového bodu toku dat použijte metody ověřování spravované identity přiřazené systémem.

1. Podrobnosti o připojení jsou v portálu Fabric v sekci Zdroje vašeho datového proudu událostí.

2. Na panelu podrobností pro vlastní koncový bod vyberte protokol Kafka .

3. Výběrem části Ověřování entra ID zobrazíte podrobnosti o připojení.

4. Zkopírujte podrobnosti o hodnotách pro server Bootstrap, název tématu a primární klíč připojovacího řetězce. Tyto hodnoty použijete ke konfiguraci koncového bodu toku dat.

   

   Nastavení	Popis
   Server Bootstrap	Adresa bootstrap serveru se používá pro vlastnost hostname v koncovém bodu toku dat.
   Název tématu	Název centra událostí se používá jako téma Kafka a je ve formátu es_aaaaaaaa-0000-1111-2222-bbbbbbbbbbbbbbbb.

Ověřování SASL

1. Podrobnosti o připojení jsou na portálu Fabric v části Zdroje vašeho streamu událostí.

2. Na panelu podrobností pro vlastní koncový bod vyberte protokol Kafka .

3. Výběrem oddílu Ověřování klíče SAS zobrazte podrobnosti o připojení.

4. Zkopírujte podrobnosti o hodnotách pro server Bootstrap, název tématu a primární klíč připojovacího řetězce. Tyto hodnoty použijete ke konfiguraci koncového bodu toku dat.

   

   Nastavení	Popis
   Server Bootstrap	Adresa bootstrap serveru se používá pro vlastnost hostname v koncovém bodu toku dat.
   Název tématu	Název centra událostí se používá jako téma Kafka a je ve formátu es_aaaaaaaa-0000-1111-2222-bbbbbbbbbbbbbbbb.
   Připojovací řetězec – primární klíč	Připojovací řetězec s primárním klíčem.

Vytvořte koncový bod toku dat Microsoft Fabric v reálném čase

Microsoft Fabric Real-Time Intelligence podporuje metody ověřování Simple Authentication and Security Layer (SASL), spravované identity přiřazené systémem a spravované identity přiřazené uživatelem. Podrobnosti o dostupných metodách ověřování najdete v tématu Dostupné metody ověřování.

Provozní zkušenosti

1. Na portálu pro operace IoT vyberte kartu Koncové body toku dat.

2. V části Vytvořit nový koncový bod toku dat vyberte Microsoft Fabric Real-Time Intelligence>New.

3. Zadejte následující nastavení pro koncový bod.

   

   Nastavení	Popis
   Název	Název koncového bodu toku dat.
   Hostitel	Název hostitele vlastního koncového bodu streamu událostí ve formátu *.servicebus.windows.net:9093. Použijte adresu serveru bootstrap, kterou jste si poznamenali dříve.
   Metoda ověřování	Metoda použitá k ověřování. Zvolte spravovanou identitu přiřazenou systémem pro Id Entra, spravovanou identitu přiřazenou uživatelem nebo SASL.

   Pokud zvolíte metodu ověřování SASL, musíte také zadat následující nastavení:

   Nastavení	Popis
   Typ SASL	Zvolte Prostý.
   Synchronizovaný tajný název	Zadejte název synchronizovaného tajného kódu. V clusteru se vytvoří tajný klíč Kubernetes s tímto názvem.

   Pokud chcete vytvořit nový odkaz, vyberte Přidat odkaz nebo zvolte existující odkaz na key Vault pro odkazy na uživatelské jméno a heslo.

   V případě odkazu na uživatelské jméno tajného tokenu musí být hodnota tajného tokenu přesně řetězec typu literálu $ConnectionString, nikoli odkaz na proměnnou prostředí.

   

   Když jde o odkaz na heslo tokenu, tajná hodnota musí být připojovacím řetězcem s primárním klíčem z vlastního koncového bodu streamu událostí.

   

4. Vyberte Použít pro zřízení koncového bodu.

Azure CLI

Vytvoření nebo nahrazení

Pomocí příkazu az iot ops dataflow endpoint create fabric-onelake vytvořte nebo nahraďte koncový bod toku dat Microsoft Fabric Real-Time Intelligence.

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

Tady je ukázkový příkaz pro vytvoření nebo nahrazení koncového bodu toku dat Microsoft Fabric Real-Time Intelligence s názvem fabric-realtime-endpoint:

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

Vytvoření nebo změna

Pomocí příkazu az iot ops dataflow endpoint apply vytvořte nebo upravte koncový bod toku dat pro Microsoft Fabric Real-Time Intelligence.

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

Parametr --config-file je cesta a název souboru JSON, který obsahuje vlastnosti prostředku.

V tomto příkladu předpokládejme konfigurační soubor s následujícím fabric-endpoint.json obsahem uloženým v domovském adresáři uživatele:

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

Tady je ukázkový příkaz pro vytvoření nového koncového bodu toku dat Microsoft Fabric Real-Time Intelligence s názvem fabric-realtime-endpoint:

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

Biceps

Vytvořte soubor Bicep .bicep s následujícím obsahem.

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

Pak nasaďte pomocí Azure CLI.

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

Kubernetes (Preview)

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

Vytvořte soubor manifestu .yaml Kubernetes s následujícím obsahem.

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

Pak použijte soubor manifestu na cluster Kubernetes.

kubectl apply -f <FILE>.yaml

Dostupné metody ověřování

Pro koncové body datového toku systému Fabric Real-Time Intelligence jsou k dispozici následující metody ověřování.

Spravovaná identita přiřazená systémem

Před konfigurací koncového bodu toku dat přiřaďte roli spravované identitě operací Azure IoT, která uděluje oprávnění pro připojení ke zprostředkovateli Kafka:

1. Na webu Azure Portal přejděte do instance operace Azure IoT a vyberte Přehled.
2. Zkopírujte název rozšíření uvedeného za Azure IoT Operations Arc extension. Například azure-iot-operations-xxxx7.
3. Přejděte ke cloudovému prostředku, ke kterému potřebujete udělit oprávnění. Například přejděte k oboru názvů > Event Hubs Řízení přístupu (IAM)>Přidat přiřazení role.
4. Na kartě Role vyberte příslušnou roli.
5. Na kartě Členové pro Přiřadit přístup ke vyberte možnost Uživatel, skupina nebo instanční objekt, potom vyberte + Vybrat členy a vyhledejte spravovanou identitu pro operace Azure IoT. Například azure-iot-operations-xxxx7.

Pak nakonfigurujte koncový bod toku dat pomocí nastavení spravované identity přiřazené systémem.

Provozní zkušenosti

Na stránce nastavení koncového bodu toku dat v provozním prostředí vyberte kartu Základní a pak zvolte Metodu ověřování>Spravovaná identita přiřazená systémem.

Azure CLI

Vytvoření nebo nahrazení

Použijte příkaz az iot ops dataflow endpoint create s parametrem --auth-type nastaveným na SystemAssignedManagedIdentity ověřování spravované identity přiřazené systémem.

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

Vytvoření nebo změna

Použijte příkaz az iot ops dataflow endpoint apply s parametrem --config-file.

V tomto příkladu předpokládejme konfigurační soubor s následujícím obsahem:

{
    "endpointType": "Kafka",
    "kafkaSettings": {
        "host": "fabricrealtime.servicebus.windows.net:9093",
        "authentication": {
            "method": "SystemAssignedManagedIdentity",
            "systemAssignedManagedIdentitySettings": {}
        },
        "tls": {
            "mode": "Enabled"
        }
    }
}

Biceps

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

Kubernetes (Preview)

kafkaSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      {}

Spravovaná identita přiřazená uživatelem

Pokud chcete pro ověřování použít spravovanou identitu přiřazenou uživatelem, musíte nejprve nasadit operace Azure IoT s povoleným zabezpečeným nastavením. Pak musíte nastavit spravovanou identitu přiřazenou uživatelem pro cloudová připojení. Další informace najdete v tématu Povolení nastavení zabezpečení v nasazení operací Azure IoT.

Před konfigurací koncového bodu toku dat přiřaďte spravované identitě přiřazené uživatelem roli, která uděluje oprávnění pro připojení ke zprostředkovateli Kafka:

1. V portálu Azure přejděte k cloudovému prostředku, kterému potřebujete přiřadit oprávnění. Přejděte například do oboru názvů Event Gridu >Řízení přístupu (IAM)>Přidat přiřazení role.
2. Na kartě Role vyberte příslušnou roli.
3. Na kartě Členové pro přiřazení přístupu k vyberte možnost Spravovaná identita, pak vyberte + Vyberte členy a vyhledejte vaši uživatelem přiřazenou spravovanou identitu.

Pak nakonfigurujte koncový bod toku dat s nastavením spravované identity přiřazené uživatelem.

Provozní zkušenosti

Na stránce nastavení koncového bodu toku dat v provozním prostředí vyberte kartu Základní a pak zvolte metodu ověřování>.

Azure CLI

Vytvoření nebo nahrazení

Použijte příkaz az iot ops dataflow endpoint create s parametrem --auth-type nastaveným na UserAssignedManagedIdentity při ověřování spravované identity přiřazené uživatelem.

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

Vytvoření nebo změna

Použití koncového bodu toku dat az iot ops s parametrem --config-file

V tomto příkladu předpokládejme konfigurační soubor s následujícím obsahem:

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

Biceps

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

Kubernetes (Preview)

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

SASL

Pokud chcete k ověřování použít SASL, zadejte metodu ověřování SASL a nakonfigurujte typ SASL a odkaz na tajný klíč s názvem tajného klíče, který obsahuje token SASL.

Azure Key Vault je doporučený způsob, jak synchronizovat připojovací řetězec do clusteru Kubernetes, aby na něj bylo možné odkazovat v toku dat. Aby bylo možné nakonfigurovat tento koncový bod pomocí webového uživatelského rozhraní provozního prostředí, musí být povolené nastavení zabezpečení.

Provozní zkušenosti

Na stránce nastavení koncového bodu toku dat v provozním prostředí vyberte kartu Základní a pak zvolte metody ověřování>SASL.

Zadejte následující nastavení pro koncový bod:

Nastavení	Popis
Typ SASL	Typ ověřování SASL, který se má použít. Podporované typy jsou Plain, ScramSha256a ScramSha512.
Synchronizovaný tajný název	Název tajného kódu Kubernetes, který obsahuje token SASL.
Referenční informace k uživatelskému jménu nebo tajný klíč tokenu	Odkaz na tajný klíč uživatelského jména nebo tokenu použitého pro ověřování SASL.
Odkaz na heslo tajemství tokenu	Odkaz na tajný klíč hesla nebo tokenu použitého pro ověřování SASL.

Azure CLI

Vytvoření nebo nahrazení

Použijte příkaz az iot ops dataflow endpoint create s parametrem --auth-type nastaveným Sasl pro ověřování SASL.

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

Vytvoření nebo změna

Použití koncového bodu toku dat az iot ops s parametrem --config-file

V tomto příkladu předpokládejme konfigurační soubor s následujícím obsahem:

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

Biceps

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

Kubernetes (Preview)

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>

Podporované typy SASL jsou:

• Plain
• ScramSha256
• ScramSha512

Tajný klíč musí být ve stejném oboru názvů jako koncový bod toku dat Kafka. Tajný klíč musí mít token SASL jako pár klíč-hodnota.

Rozšířené nastavení

Pokročilá nastavení pro tento koncový bod jsou stejná jako pokročilá nastavení pro koncové body Azure Event Hubs.

Další kroky

Další informace o tocích dat najdete v tématu Vytvoření toku dat.