将事件集线器连接到Azure Databricks

Question

我想在azuredatabricks中添加用于连接到事件中心的库。我将用python写笔记本。那么我应该添加哪个库来连接事件中心呢

根据我的搜索到现在我得到了一个火花连接库在Maven坐标。但是我不认为我能用python导入它

Answer 1

Azure事件中心的结构化流式集成最终在JVM上运行，因此您需要从下面的Maven坐标导入库：

 groupId = com.microsoft.azure
  artifactId = azure-eventhubs-spark_2.11
  version = 2.3.10

注意：对于Python应用程序，部署应用程序时需要添加上述库及其依赖项

有关详细信息，请参阅“Structured streaming + Event Hubs Integration Guide for PySpark”和“Attach libraries to Spark Cluster”

此外，您还可以参考SO线程，它解决了类似的问题

希望这有帮助