在Dataflowtask中处理具有动态列名的源

Question

我应该从一个数据源读取数据，它的列名是永久更改的(列名是date)：

​

​

我想把它写在一个表中，我有这样一个映射：

​

当然，如果列名更改了，那么到下一次运行时，它就不再起作用了。你知道吗，我怎么能动态地指定coumn的名字呢？或者我如何在广播中读取列名？

是否可以通过每次运行生成一个具有新列名的新表？我该怎么做呢？

Answer 1

您可以使用BiML，它在运行时根据元数据动态生成您的包。