通过CSV文件，通过KAFKA API将数据从Azure Databricks流到Azure事件中心

Question

我是Azure Databricks和Event Hubs的新手。我一直在努力使用SPARK和KAFKA API将数据从Databrick流传输到事件中心。我想要流的数据在.CSV文件中。流启动，但输入率的仪表板为空白。这是一个代码段：

def write_to_event_hub(df:DataFrame, topic: str, bootstrap_servers: str, config: str, checkpoint_path: str):
    print("Producing to even hub via Kafka")
    df.writeStream\
    .format("kafka")\
    .option("topic", topic)\
    .option("kafka.bootstrap.servers", bootstrap_servers)\
    .option("kafka.sasl.mechanism", "PLAIN")\
    .option("kafka.security.protocol", "SASL_SSL")\
    .option("kafka.sasl.jaas.config", config)\
    .option("checkpointLocation", checkpoint_path)\
    .start()
    


write_to_event_hub(streaming_df, topic, bootstrap_servers, sasl_jaas_config, "./checkpoint")

和用于生成数据的代码：

streaming_df = spark.readStream.option("header", "true").schema(location_schema).csv(f"{path}").select("*")

我还附加了带有配置的图片。主题是事件中心的名称，连接字符串的格式：＆lt; endpoint = sb：//xxxx.servicebus.windows.windows.net/; sharedAccessKeyname = xxxxx; sharedaccesskey = xxxx＆gt = xxxx＆gt = xxxx＆gt = xxxx＆gt = xxxx＆gt ;

（我想连接到名称空间中的一个事件中心） 我阅读要流或配置的数据的方式可能有问题。有什么想法吗？

谢谢！