Azure数据砖中的CSV摄入错误 - 文件读取错误
我的任务是使用Python执行CSV文件的数据摄入。我正在使用以下代码块，并获取未找到文件的错误事件，尽管该位置是正确的。
spark.read.format("Filelocation") \
.option("file.format", "csv") \
.option("file.schemaLocation", "checkpoint") \
.load("source_data") \
.writeStream \
.option("mergeSchema", "true") \
.option("My_Checkpoint", "Checkpoint path") \
.start("target")
我没有错误的线索。任何帮助都将受到赞赏。
My task is to perform data ingestion of CSV file using python. I am using the following code block and getting error of file not found eventhough the location is right.
spark.read.format("Filelocation") \
.option("file.format", "csv") \
.option("file.schemaLocation", "checkpoint") \
.load("source_data") \
.writeStream \
.option("mergeSchema", "true") \
.option("My_Checkpoint", "Checkpoint path") \
.start("target")
I have no clue of the error. Any help is appreciated.
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
这是我从您的代码块中观察到的简单读取语句错误。
在第一行中使用上面的代码块，而不是
spark.read.format（“ fileLocation”），其余语句如原样。It's a simple read statement error that I have observed from your code block.
Use the above code block in the first line instead of
spark.read.format("Filelocation")and remaining statements are as it is.