【发布时间】:2018-06-04 07:39:40
【问题描述】:
我正在尝试使用 Data Factory 和 Databricks 实现一个流程,以将数据摄取到 Data Lake 并将其全部转换为标准格式,即 parquet。因此,我们将拥有一个原始数据层和一个干净/标准化的数据层。
当源系统是数据库或分隔文件时,它(相对)容易,但在某些情况下,我们会有 excel 源。我一直在使用com.crealytics.spark.excel 测试转换过程,这没问题,因为我们可以推断架构但它无法遍历多个工作表或获取工作表名称列表以使我能够迭代认为每个转换为单个工作表文件。
我需要它尽可能动态,以便我们可以摄取几乎任何文件,无论其类型或架构。
有没有人知道这样做的任何替代方法?如有必要,我愿意远离数据块,例如带有自定义 C# 脚本的 Azure Batch。
提前致谢!
【问题讨论】:
标签: apache-spark apache-spark-sql azure-data-lake databricks