python - 使用服务主体的流式事件中心

Question

如何将事件中心数据流式传输到具有以下详细信息的 spark 数据帧中：

1. 服务负责人
2. 事件中心命名空间
3. 事件中心名称
4. 消费群

我需要将数据输入火花数据框。我没有事件中心连接字符串。

Answer 1

一种解决方法如下

第 1 步：使用以下任一命令生成连接字符串。

• 使用 Azure CLI 获取连接字符串

  az eventhubs namespace authorization-rule keys list --resource-group MYRESOURCEGROUP --namespace-name MY
  

• 使用 Azure PowerShell 获取连接字符串

  Get-AzEventHubKey -ResourceGroupName MYRESOURCEGROUP -NamespaceName MYEHUBNAMESPACE -Aut
  

第 2 步：然后，要读取数据，您可以按照Example1、Example2中的任何一个示例进行操作。

参考：

事件中心获取连接字符串 · MicrosoftDocs