在数据湖中,我有模式为 yyyyMM_data.csv 的文件名。现在我想阅读前 3 天的数据。我正在使用下面的代码 -
DECLARE @ReportDate DateTime= DateTime.Parse("05/08/2017");
DECLARE @FeatureSummaryInput string=@"/FolderPath/{InputFileDate:yyyy}{InputFileDate:MM}_data.csv";
@FeaturedUsed =
EXTRACT Id string,InputFileDate DateTime
FROM @FeatureSummaryInput
USING Extractors.Csv(silent : true, skipFirstNRows : 1);
@FeaturedUsed=
SELECT *
FROM @FeaturedUsed
WHERE InputFileDate BETWEEN @ReportDate.AddDays(-3) AND @ReportDate;
如果我运行上面的代码,它会以空输入运行。如果我遗漏了什么,请告诉我。为什么它没有读取正确的文件?
似乎我们需要在文件名模式中使用“day”才能工作。