Databricks连接Azure Event Hub时的Apache Spark Streaming连接字符串错误

先拆解你遇到的两个异常，咱们一步步来排查：

1. AttributeError: 'str' object has no attribute '_jvm' #

这个是最关键的直接问题——代码里的self.connectionProperties.sc居然是字符串类型，而不是预期的SparkContext实例！正常情况下sc应该指向SparkContext对象，它自带_jvm属性，用来调用Java端的EventHubsUtils工具类。

解决步骤：

• 先查self.connectionProperties的初始化逻辑，看看sc属性是怎么赋值的，是不是不小心把SparkContext的打印字符串（比如print(sc)的输出）存进去了，而非实际的SparkContext对象。
• 确保sc指向当前Spark应用的有效实例：如果你用的是SparkSession，可以直接取spark.sparkContext来赋值，而不是随便传个字符串。

2. Exception: ERROR: 'int' object has no attribute 'value' #

这个错误大概率是第一个问题引发的连锁反应：当sc是字符串时，调用_jvm直接失败，后续参数传递或错误处理过程中，某个预期带value属性的对象被替换成了int类型（比如错误码），进而触发这个异常。

额外检查点：

• 确认connectionString是标准字符串格式，没有被错误转换成int类型（比如误把配置项的索引当成了连接字符串）。
• 调用EventHubsUtils.encrypt()时，参数必须是有效的Event Hub连接字符串，不能传其他类型的值。

给你一个修正后的代码参考，加了必要的类型校验：

def EventHubConnectionProperties(self, processId, startOffset, endTime):
    ehConf = {}
    
    # 先校验sc是否为有效SparkContext实例
    if not hasattr(self.connectionProperties.sc, '_jvm'):
        raise ValueError("self.connectionProperties.sc 必须是有效的SparkContext实例")
    
    # 校验连接字符串类型
    connection_string = self.connectionProperties.connectionString  # 假设这里存的是正确的连接字符串
    if not isinstance(connection_string, str):
        raise TypeError(f"connectionString必须是字符串类型，当前为{type(connection_string)}")
    
    # 调用加密方法
    encrypted_conn = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connection_string)
    ehConf['eventhubs.connectionString'] = encrypted_conn
    
    return ehConf

核心逻辑就是先确保依赖的sc是真实的SparkContext对象，再校验连接字符串的类型正确性，这两个问题解决后，后续的异常应该就能消失。

内容的提问来源于stack exchange，提问作者Patterson