Databricks 连接到 Azure 事件中心的 Apache Spark Streaming 连接字符串错误
我收到错误：
Exception: ERROR: 'int' object has no attribute 'value'
AttributeError: 'str' object has no attribute '_jvm'
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
当我尝试调用以下函数时：
def EventHubConnectionProperties(self,processId,startOffset,endTime):
ehConf = {}
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
有人有任何想法吗？
I'm getting the error:
Exception: ERROR: 'int' object has no attribute 'value'
AttributeError: 'str' object has no attribute '_jvm'
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
When I try and call the following function:
def EventHubConnectionProperties(self,processId,startOffset,endTime):
ehConf = {}
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
Does anyone have any thoughts?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
它应该按如下方式使用 -
It should be used as below -