Integrar os Hubs de Eventos do Azure com o Conector de Serviço

Esta página mostra métodos e clientes de autenticação com suporte e mostra o código de exemplo que você pode usar para conectar os Hubs de Eventos do Azure a outros serviços de nuvem usando o Service Connector. Você ainda poderá se conectar aos Hubs de Eventos em outras linguagens de programação sem usar o Conector de Serviço. Esta página também mostra nomes e valores de variáveis de ambiente padrão (ou configuração do Spring Boot) que você obtém ao criar conexões de serviço.

Serviço de computação com suporte

O Service Connector pode ser usado para conectar os seguintes serviços de computação aos Hubs de Eventos do Azure:

• Serviço de aplicativo do Azure
• Funções do Azure
• Aplicativos de Contêiner do Azure
• Azure Spring Apps

Tipos de autenticação e tipos de cliente com suporte

A tabela abaixo mostra quais combinações de tipos de cliente e métodos de autenticação têm suporte para conectar seu serviço de computação aos Hubs de Eventos do Azure usando o Service Connector. Um "Sim" indica que a combinação é suportada, enquanto um "Não" indica que ela não é suportada.

Tipo de cliente	Identidade gerenciada atribuída pelo sistema	Identidade gerenciada atribuída pelo usuário	Cadeia de conexão/segredo	Entidade de serviço
.NET	Sim	Sim	Sim	Yes
Go	Sim	Sim	Sim	Sim
Java	Sim	Sim	Sim	Yes
Java – Spring Boot	Sim	Sim	Sim	Yes
Kafka - Spring Boot	Sim	Sim	Sim	Sim
Node.js	Sim	Sim	Sim	Sim
Python	Sim	Sim	Sim	Yes
Nenhum	Sim	Sim	Sim	Yes

Esta tabela indica que todas as combinações de tipos de cliente e métodos de autenticação na tabela são suportadas. Todos os tipos de cliente podem usar qualquer um dos métodos de autenticação para se conectar aos Hubs de Eventos do Azure usando o Service Connector.

Nomes de variável de ambiente padrão ou propriedades de aplicativo

Use os detalhes de conexão abaixo para conectar os serviços de computação aos Hubs de Eventos. Para cada exemplo abaixo, substitua os textos de espaço reservado <Event-Hubs-namespace>, <access-key-name>, <access-key-value>, <client-ID>, <client-secret> e <tenant-id> pelo seguinte: namespace dos Hubs de Eventos, nome da chave de acesso compartilhada, valor da chave de acesso compartilhada, ID do cliente, segredo do cliente e ID do locatário. Para obter mais informações sobre convenções de nomenclatura, consulte o artigo Internos do Service Connector.

Identidade gerenciada atribuída pelo sistema

Tipo de cliente SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.cloud.azure.eventhub.namespace	Namespace do Hubs de Eventos	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.eventhubs.namespace	Namespace dos Hubs de Eventos para a versão do Spring Cloud Azure acima de 4.0	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.eventhubs.credential.managed-identity-enabled	Se a identidade gerenciada deve ser habilitada	true

Tipo de cliente Kafka-SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.kafka.bootstrap-servidores	Servidor de inicialização Kafka	<Event-Hub-namespace>.servicebus.windows.net

Outros tipos de clientes

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE	Namespace do Hubs de Eventos	<Event-Hubs-namespace>.servicebus.windows.net

Código de exemplo

Consulte as etapas e o código abaixo para se conectar aos Hubs de Eventos do Azure usando uma identidade gerenciada atribuída pelo sistema.

.NET

1. Instale as dependências.

   dotnet add package Azure.Identity
   dotnet add package Azure.Messaging.EventHubs
   

2. Autentique-se usando Azure.Identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   using System; 
   sing Azure.Identity;
   using Azure.Messaging.EventHubs;
   
   // Uncomment the following lines according to the authentication type.
   // system-assigned managed identity
   // var credential = new DefaultAzureCredential();
   
   // user-assigned managed identity
   // var credential = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   //     });
   
   // service principal 
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTSECRET");
   // var credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   var fullyQualifiedNamespace = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   var eventHubName = "<NAME OF THE EVENT HUB>";
   
   // Example of sending events
   var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Java

1. Adicione as dependências a seguir no seu arquivo pom.xml:

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-eventhubs</artifactId>
       <version>5.15.0</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   // Uncomment the following lines according to the authentication type.
   // for system-managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();
   
   // for user-assigned managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //     .build();
   
   // for service principal
   // ClientSecretCredential credential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_EVENTHUB_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_EVENTHUB_TENANTID"))
   //   .build();
   
   String namespace = System.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   
   // Example of sending events
   EventProcessorClientBuilder eventProcessorClientBuilder = new EventProcessorClientBuilder()
       .consumerGroup(EventHubClientBuilder.DEFAULT_CONSUMER_GROUP_NAME)
       .credential(namespace, "<event-hub-name>", credential)
   EventProcessorClient eventProcessorClient = eventProcessorClientBuilder.buildEventProcessorClient();    
   

SpringBoot

Consulte Spring Cloud Stream com Hubs de Eventos do Azure e Usando o Spring Integration para Hubs de Eventos do Azure para configurar seu aplicativo Spring. As propriedades de configuração são adicionadas ao Spring Apps pelo Service Connector. Dois conjuntos de propriedades de configuração são fornecidos dependendo da versão do Spring Cloud Azure (abaixo de 4.0 e acima de 4.0) usada. Para obter mais informações sobre as alterações na biblioteca do Spring Cloud Azure, consulte o Guia de migração do Spring Cloud Azure.

Kafka-SpringBoot

Consulte Usar o Spring Kafka com Hubs de Eventos do Azure para a API do Kafka para configurar seu aplicativo Spring. As propriedades de configuração acima são definidas como Spring Apps by Service Connector.

Python

1. Instale as dependências.

   pip install azure-eventhub
   pip install azure-identity
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import os
   from azure.eventhub import EventData
   from azure.eventhub.aio import EventHubProducerClient
   
   # Uncomment the following lines according to the authentication type.
   # system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # service principal
   # tenant_id = os.getenv('AZURE_EVENTHUB_TENANTID')
   # client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # client_secret = os.getenv('AZURE_EVENTHUB_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   namespace = os.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   EVENT_HUB_NAME = "EVENT_HUB_NAME"
   
   # Example of sending events
   producer = EventHubProducerClient(
       fully_qualified_namespace=namespace,
       eventhub_name=EVENT_HUB_NAME,
       credential=cred,
   )
   

Go

1. Instale as dependências.

   go get github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs
   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   

2. Autentique-se usando azidentity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import (
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
       "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs"
   )
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
   // for user-assigned managed identity
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // azidentity.ManagedIdentityCredentialOptions.ID := clientid
   // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
   // cred, err := azidentity.NewManagedIdentityCredential(options)
   
   // for service principal
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // tenantid := os.Getenv("AZURE_EVENTHUB_TENANTID")
   // clientsecret := os.Getenv("AZURE_EVENTHUB_CLIENTSECRET")
   // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
   namespace := os.Getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   
   // Example of sending events
   producerClient, err := azeventhubs.NewProducerClient(namespace, "<eventhub-name>", defaultAzureCred, nil)
   if err != nil {
       panic(err)
   }
   

NodeJS

1. Instale as dependências.

   npm install @azure/event-hubs
   npm install @azure/identity
   

2. Autentique-se usando @azure/identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   const { EventHubProducerClient } = require("@azure/event-hubs");
   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // const credential = new DefaultAzureCredential();
   
   // for user-assigned managed identity
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // for service principal
   // const tenantId = process.env.AZURE_EVENTHUB_TENANTID;
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const clientSecret = process.env.AZURE_EVENTHUB_CLIENTSECRET;
   // const credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   const namespace = process.env.AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE; 
   const eventHubName = "EVENT HUB NAME";
   
   // Example of sending events
   const producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Outras

Para outros idiomas, você pode usar as propriedades de configuração de conexão que o Service Connector define para as variáveis de ambiente para se conectar aos Hubs de Eventos do Azure. Para obter detalhes sobre variáveis de ambiente, consulte Integrar Hubs de Eventos do Azure com o Service Connector.

Identidade gerenciada atribuída pelo usuário

Tipo de cliente SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.cloud.azure.eventhub.namespace	Namespace do Hubs de Eventos	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.client-id	Sua ID de cliente	<client-ID>
spring.cloud.azure.eventhubs.namespace	Namespace dos Hubs de Eventos para a versão do Spring Cloud Azure acima de 4.0	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.eventhubs.credential.client-id	Sua ID de cliente para a versão do Spring Cloud Azure acima de 4.0	<client-ID>
spring.cloud.azure.eventhubs.credential.managed-identity-enabled	Se a identidade gerenciada deve ser habilitada	true

Tipo de cliente Kafka-SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.kafka.bootstrap-servidores	Servidor de inicialização Kafka	<Event-Hub-namespace>.servicebus.windows.net
spring.kafka.properties.azure.credential.managed-identity-enabled	Se a identidade gerenciada deve ser habilitada	true
spring.kafka.properties.azure.credential.client-id	Sua ID de cliente	<client-ID>

Outros tipos de clientes

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE	Namespace do Hubs de Eventos	<Event-Hubs-namespace>.servicebus.windows.net
AZURE_EVENTHUB_CLIENTID	Sua ID de cliente	<client-ID>

Código de exemplo

Consulte as etapas e o código abaixo para se conectar aos Hubs de Eventos do Azure usando uma identidade gerenciada atribuída pelo usuário.

.NET

1. Instale as dependências.

   dotnet add package Azure.Identity
   dotnet add package Azure.Messaging.EventHubs
   

2. Autentique-se usando Azure.Identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   using System; 
   sing Azure.Identity;
   using Azure.Messaging.EventHubs;
   
   // Uncomment the following lines according to the authentication type.
   // system-assigned managed identity
   // var credential = new DefaultAzureCredential();
   
   // user-assigned managed identity
   // var credential = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   //     });
   
   // service principal 
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTSECRET");
   // var credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   var fullyQualifiedNamespace = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   var eventHubName = "<NAME OF THE EVENT HUB>";
   
   // Example of sending events
   var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Java

1. Adicione as dependências a seguir no seu arquivo pom.xml:

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-eventhubs</artifactId>
       <version>5.15.0</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   // Uncomment the following lines according to the authentication type.
   // for system-managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();
   
   // for user-assigned managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //     .build();
   
   // for service principal
   // ClientSecretCredential credential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_EVENTHUB_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_EVENTHUB_TENANTID"))
   //   .build();
   
   String namespace = System.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   
   // Example of sending events
   EventProcessorClientBuilder eventProcessorClientBuilder = new EventProcessorClientBuilder()
       .consumerGroup(EventHubClientBuilder.DEFAULT_CONSUMER_GROUP_NAME)
       .credential(namespace, "<event-hub-name>", credential)
   EventProcessorClient eventProcessorClient = eventProcessorClientBuilder.buildEventProcessorClient();    
   

SpringBoot

Consulte Spring Cloud Stream com Hubs de Eventos do Azure e Usando o Spring Integration para Hubs de Eventos do Azure para configurar seu aplicativo Spring. As propriedades de configuração são adicionadas ao Spring Apps pelo Service Connector. Dois conjuntos de propriedades de configuração são fornecidos dependendo da versão do Spring Cloud Azure (abaixo de 4.0 e acima de 4.0) usada. Para obter mais informações sobre as alterações na biblioteca do Spring Cloud Azure, consulte o Guia de migração do Spring Cloud Azure.

Kafka-SpringBoot

Consulte Usar o Spring Kafka com Hubs de Eventos do Azure para a API do Kafka para configurar seu aplicativo Spring. As propriedades de configuração acima são definidas como Spring Apps by Service Connector.

Python

1. Instale as dependências.

   pip install azure-eventhub
   pip install azure-identity
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import os
   from azure.eventhub import EventData
   from azure.eventhub.aio import EventHubProducerClient
   
   # Uncomment the following lines according to the authentication type.
   # system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # service principal
   # tenant_id = os.getenv('AZURE_EVENTHUB_TENANTID')
   # client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # client_secret = os.getenv('AZURE_EVENTHUB_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   namespace = os.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   EVENT_HUB_NAME = "EVENT_HUB_NAME"
   
   # Example of sending events
   producer = EventHubProducerClient(
       fully_qualified_namespace=namespace,
       eventhub_name=EVENT_HUB_NAME,
       credential=cred,
   )
   

Go

1. Instale as dependências.

   go get github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs
   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   

2. Autentique-se usando azidentity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import (
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
       "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs"
   )
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
   // for user-assigned managed identity
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // azidentity.ManagedIdentityCredentialOptions.ID := clientid
   // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
   // cred, err := azidentity.NewManagedIdentityCredential(options)
   
   // for service principal
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // tenantid := os.Getenv("AZURE_EVENTHUB_TENANTID")
   // clientsecret := os.Getenv("AZURE_EVENTHUB_CLIENTSECRET")
   // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
   namespace := os.Getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   
   // Example of sending events
   producerClient, err := azeventhubs.NewProducerClient(namespace, "<eventhub-name>", defaultAzureCred, nil)
   if err != nil {
       panic(err)
   }
   

NodeJS

1. Instale as dependências.

   npm install @azure/event-hubs
   npm install @azure/identity
   

2. Autentique-se usando @azure/identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   const { EventHubProducerClient } = require("@azure/event-hubs");
   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // const credential = new DefaultAzureCredential();
   
   // for user-assigned managed identity
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // for service principal
   // const tenantId = process.env.AZURE_EVENTHUB_TENANTID;
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const clientSecret = process.env.AZURE_EVENTHUB_CLIENTSECRET;
   // const credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   const namespace = process.env.AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE; 
   const eventHubName = "EVENT HUB NAME";
   
   // Example of sending events
   const producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Outras

Para outros idiomas, você pode usar as propriedades de configuração de conexão que o Service Connector define para as variáveis de ambiente para se conectar aos Hubs de Eventos do Azure. Para obter detalhes sobre variáveis de ambiente, consulte Integrar Hubs de Eventos do Azure com o Service Connector.

Connection string

Tipo de cliente SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.cloud.azure.storage.connection-string	Cadeia de conexão dos Hubs de Eventos	Endpoint=sb://servicelinkertesteventhub.servicebus.windows.net/;SharedAccessKeyName=<access-key-name>;SharedAccessKey=<access-key-value>
spring.cloud.azure.eventhubs.connection-string	Cadeia de conexão dos Hubs de Eventos para a versão do Spring Cloud Azure acima de 4.0	Endpoint=sb://servicelinkertesteventhub.servicebus.windows.net/;SharedAccessKeyName=<access-key-name>;SharedAccessKey=<access-key-value>

Tipo de cliente Kafka-SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.cloud.azure.eventhubs.connection-string	Cadeia de conexão dos Hubs de Eventos	Endpoint=sb://servicelinkertesteventhub.servicebus.windows.net/;SharedAccessKeyName=<access-key-name>;SharedAccessKey=<access-key-value>

Outros tipos de clientes

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
AZURE_EVENTHUB_CONNECTIONSTRING	Cadeia de conexão dos Hubs de Eventos	Endpoint=sb://<Event-Hubs-namespace>.servicebus.windows.net/;SharedAccessKeyName=<access-key-name>;SharedAccessKey=<access-key-value>

Código de exemplo

Consulte as etapas e o código abaixo para se conectar aos Hubs de Eventos do Azure usando uma cadeia de conexão.

.NET

1. Instalar dependência.

   dotnet add package Azure.Messaging.EventHubs
   

2. Obtenha a cadeia de conexão da variável de ambiente adicionada pelo Service Connector.

   using System; 
   using Azure.Messaging.EventHubs;
   
   string connectionString = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CONNECTIONSTRING");
   var eventHubName = "<NAME OF THE EVENT HUB>";
   var consumerGroup = EventHubConsumerClient.DefaultConsumerGroupName;
   
   var producer = new EventHubProducerClient(connectionString, eventHubName);
   var consumer = new EventHubConsumerClient(consumerGroup, connectionString, eventHubName);
   

Java

1. Adicione a seguinte dependência no arquivo pom.xml :

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-eventhubs</artifactId>
       <version>5.15.0</version>
   </dependency>
   

2. Obtenha a cadeia de conexão da variável de ambiente adicionada pelo Service Connector.

   String connectionStr = System.getenv("AZURE_EVENTHUB_CONNECTIONSTRING");
   
   // Example of sending events
   EventHubProducerAsyncClient producer = new EventHubClientBuilder()
       .connectionString(
           connStr,
           "<event-hub-name>")
       .buildAsyncProducerClient();
   

SpringBoot

Consulte Spring Cloud Stream com Hubs de Eventos do Azure e Usando o Spring Integration para Hubs de Eventos do Azure para configurar seu aplicativo Spring. As propriedades de configuração são adicionadas ao Spring Apps pelo Service Connector. Dois conjuntos de propriedades de configuração são fornecidos dependendo da versão do Spring Cloud Azure (abaixo de 4.0 e acima de 4.0) usada. Para obter mais informações sobre as alterações na biblioteca do Spring Cloud Azure, consulte o Guia de migração do Spring Cloud Azure.

Kafka-SpringBoot

Consulte Usar o Spring Kafka com Hubs de Eventos do Azure para a API do Kafka para configurar seu aplicativo Spring. As propriedades de configuração acima são definidas como Spring Apps by Service Connector.

Python

1. Instalar dependência.

   pip install azure-eventhub
   

2. Obtenha a cadeia de conexão da variável de ambiente adicionada pelo Service Connector.

   import os
   from azure.eventhub import EventData
   from azure.eventhub.aio import EventHubProducerClient
   
   CONN_STR = os.environ["AZURE_EVENTHUB_CONNECTIONSTRING"]
   EVENT_HUB_NAME = "EVENT_HUB_NAME"
   
   # Example of sending events
   producer = EventHubProducerClient.from_connection_string(
       conn_str=EVENT_HUB_CONNECTION_STR, eventhub_name=EVENT_HUB_NAME
   )
   

Go

1. Instalar dependência.

   go get github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs
   

2. Obtenha a cadeia de conexão da variável de ambiente adicionada pelo Service Connector.

   import (
       "context"
   
       "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs"
   )
   
   connectionString := os.Getenv("AZURE_EVENTHUB_CONNECTIONSTRING")
   
   // Example of sending events
   producerClient, err := azeventhubs.NewProducerClientFromConnectionString(connectionString, "EVENT HUB NAME", nil)
   

NodeJS

1. Instalar dependência.

   npm install @azure/event-hubs
   

2. Obtenha a cadeia de conexão da variável de ambiente adicionada pelo Service Connector.

   const { EventHubProducerClient } = require("@azure/event-hubs");
   
   const eventHubName = "EVENT HUB NAME";
   const connection_string = process.env.AZURE_EVENTHUB_CONNECTIONSTRING;
   
   // Example of sending events
   const producer = new EventHubProducerClient(connectionString, eventHubName);
   

Outras

Para outros idiomas, você pode usar as propriedades de configuração de conexão que o Service Connector define para as variáveis de ambiente para se conectar aos Hubs de Eventos do Azure. Para obter detalhes sobre variáveis de ambiente, consulte Integrar Hubs de Eventos do Azure com o Service Connector.

Entidade de serviço

Tipo de cliente SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.cloud.azure.eventhub.namespace	Namespace do Hubs de Eventos	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.client-id	Sua ID de cliente	<client-ID>
spring.cloud.azure.tenant-id	Seu segredo do cliente	<client-secret>
spring.cloud.azure.client-secret	Sua ID de locatário	<tenant-id>
spring.cloud.azure.eventhubs.namespace	Namespace dos Hubs de Eventos para a versão do Spring Cloud Azure acima de 4.0	<Event-Hub-namespace>.servicebus.windows.net
spring.cloud.azure.eventhubs.credential.client-id	Sua ID de cliente para a versão do Spring Cloud Azure acima de 4.0	<client-ID>
spring.cloud.azure.eventhubs.credential.client-secret	Seu segredo de cliente para a versão do Spring Cloud Azure acima de 4.0	<client-secret>
spring.cloud.azure.eventhubs.profile.tenant-id	Sua ID de locatário para a versão do Spring Cloud Azure acima de 4.0	<tenant-id>

Tipo de cliente Kafka-SpringBoot

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
spring.kafka.bootstrap-servidores	Servidor de inicialização Kafka	<Event-Hub-namespace>.servicebus.windows.net
spring.kafka.properties.azure.credential.client-id	Sua ID de cliente	<client-ID>
spring.kafka.properties.azure.credential.client-secret	Seu segredo do cliente	<client-secret>
spring.kafka.properties.azure.profile.tenant-id	Sua ID de locatário	<tenant-id>

Outros tipos de clientes

Nome da variável de ambiente padrão	Descrição	Valor de exemplo
AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE	Namespace do Hubs de Eventos	<Event-Hubs-namespace>.servicebus.windows.net
AZURE_EVENTHUB_CLIENTID	Sua ID de cliente	<client-ID>
AZURE_EVENTHUB_CLIENTSECRET	Seu segredo do cliente	<client-secret>
AZURE_EVENTHUB_TENANTID	Sua ID de locatário	<tenant-id>

Código de exemplo

Consulte as etapas e o código abaixo para se conectar aos Hubs de Eventos do Azure usando uma entidade de serviço.

.NET

1. Instale as dependências.

   dotnet add package Azure.Identity
   dotnet add package Azure.Messaging.EventHubs
   

2. Autentique-se usando Azure.Identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   using System; 
   sing Azure.Identity;
   using Azure.Messaging.EventHubs;
   
   // Uncomment the following lines according to the authentication type.
   // system-assigned managed identity
   // var credential = new DefaultAzureCredential();
   
   // user-assigned managed identity
   // var credential = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   //     });
   
   // service principal 
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_CLIENTSECRET");
   // var credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   var fullyQualifiedNamespace = Environment.GetEnvironmentVariable("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   var eventHubName = "<NAME OF THE EVENT HUB>";
   
   // Example of sending events
   var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Java

1. Adicione as dependências a seguir no seu arquivo pom.xml:

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-eventhubs</artifactId>
       <version>5.15.0</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   // Uncomment the following lines according to the authentication type.
   // for system-managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();
   
   // for user-assigned managed identity
   // DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //     .build();
   
   // for service principal
   // ClientSecretCredential credential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_EVENTHUB_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_EVENTHUB_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_EVENTHUB_TENANTID"))
   //   .build();
   
   String namespace = System.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE");
   
   // Example of sending events
   EventProcessorClientBuilder eventProcessorClientBuilder = new EventProcessorClientBuilder()
       .consumerGroup(EventHubClientBuilder.DEFAULT_CONSUMER_GROUP_NAME)
       .credential(namespace, "<event-hub-name>", credential)
   EventProcessorClient eventProcessorClient = eventProcessorClientBuilder.buildEventProcessorClient();    
   

SpringBoot

Consulte Spring Cloud Stream com Hubs de Eventos do Azure e Usando o Spring Integration para Hubs de Eventos do Azure para configurar seu aplicativo Spring. As propriedades de configuração são adicionadas ao Spring Apps pelo Service Connector. Dois conjuntos de propriedades de configuração são fornecidos dependendo da versão do Spring Cloud Azure (abaixo de 4.0 e acima de 4.0) usada. Para obter mais informações sobre as alterações na biblioteca do Spring Cloud Azure, consulte o Guia de migração do Spring Cloud Azure.

Kafka-SpringBoot

Consulte Usar o Spring Kafka com Hubs de Eventos do Azure para a API do Kafka para configurar seu aplicativo Spring. As propriedades de configuração acima são definidas como Spring Apps by Service Connector.

Python

1. Instale as dependências.

   pip install azure-eventhub
   pip install azure-identity
   

2. Autentique-se usando azure-identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import os
   from azure.eventhub import EventData
   from azure.eventhub.aio import EventHubProducerClient
   
   # Uncomment the following lines according to the authentication type.
   # system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # service principal
   # tenant_id = os.getenv('AZURE_EVENTHUB_TENANTID')
   # client_id = os.getenv('AZURE_EVENTHUB_CLIENTID')
   # client_secret = os.getenv('AZURE_EVENTHUB_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   namespace = os.getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   EVENT_HUB_NAME = "EVENT_HUB_NAME"
   
   # Example of sending events
   producer = EventHubProducerClient(
       fully_qualified_namespace=namespace,
       eventhub_name=EVENT_HUB_NAME,
       credential=cred,
   )
   

Go

1. Instale as dependências.

   go get github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs
   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   

2. Autentique-se usando azidentity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   import (
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
       "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs"
   )
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
   // for user-assigned managed identity
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // azidentity.ManagedIdentityCredentialOptions.ID := clientid
   // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
   // cred, err := azidentity.NewManagedIdentityCredential(options)
   
   // for service principal
   // clientid := os.Getenv("AZURE_EVENTHUB_CLIENTID")
   // tenantid := os.Getenv("AZURE_EVENTHUB_TENANTID")
   // clientsecret := os.Getenv("AZURE_EVENTHUB_CLIENTSECRET")
   // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
   namespace := os.Getenv("AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE")
   
   // Example of sending events
   producerClient, err := azeventhubs.NewProducerClient(namespace, "<eventhub-name>", defaultAzureCred, nil)
   if err != nil {
       panic(err)
   }
   

NodeJS

1. Instale as dependências.

   npm install @azure/event-hubs
   npm install @azure/identity
   

2. Autentique-se usando @azure/identity e obtenha o namespace Hubs de Eventos do Azure das variáveis de ambiente adicionadas pelo Service Connector. Ao usar o código abaixo, descompacte a parte do snippet de código para o tipo de autenticação que você deseja usar.

   const { EventHubProducerClient } = require("@azure/event-hubs");
   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   
   // Uncomment the following lines according to the authentication type.
   // for system-assigned managed identity
   // const credential = new DefaultAzureCredential();
   
   // for user-assigned managed identity
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // for service principal
   // const tenantId = process.env.AZURE_EVENTHUB_TENANTID;
   // const clientId = process.env.AZURE_EVENTHUB_CLIENTID;
   // const clientSecret = process.env.AZURE_EVENTHUB_CLIENTSECRET;
   // const credential = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   const namespace = process.env.AZURE_EVENTHUB_FULLYQUALIFIEDNAMESPACE; 
   const eventHubName = "EVENT HUB NAME";
   
   // Example of sending events
   const producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   

Outras

Para outros idiomas, você pode usar as propriedades de configuração de conexão que o Service Connector define para as variáveis de ambiente para se conectar aos Hubs de Eventos do Azure. Para obter detalhes sobre variáveis de ambiente, consulte Integrar Hubs de Eventos do Azure com o Service Connector.

Próximas etapas

Siga os tutoriais listados abaixo para saber mais sobre o Conector de Serviço.

Saiba mais sobre os conceitos do Conector de Serviço