处理简单的 csv 文件时出错

Getting Error while processing simple csv file

我正在尝试使用以下 usql 脚本处理 Source 文件,但在将作业提交给 ADLA 时出现错误,如下面的屏幕截图所示。

我认为这是从 openoffice 创建的 csv 问题,所以从 excel 重新创建 但结果是一样的。如果有人可以就我在这里缺少的内容提供建议,我将不胜感激。

DECLARE @in  string = "/output/SearchLog-from-Data-Lake-cp.csv";
DECLARE @out string = "/output/trckout.csv";

 @CustData =
     EXTRACT CustomerUniqueID   int     ,
     CusLocationID              int   ,
     [PIM]                      int   ,
     AgeGender                  string  ,
     Mood                       string  ,
//     StartDate                  DateTime,
     ImagePath                  string  ,
//     EndDate                    DateTime,
     OutletName                 string  ,
     OutletStreet               string  ,
     OutletCity                 string  ,
     OutletState                string  ,
     OutletAreaCode             string  ,
     OutletCountry              string  ,
     Outletlandmark             string  ,
     OutletWeather              string  ,
     BrandName                  string  ,
     BrandStreet                string  ,
     BrandCity                  string  ,
     BrandState                 string  ,
     BrandAreaCode              string  ,
     BrandCountry               string  ,
     Brandlandmark              string  ,
     CamLocName                 string  ,
     CamAddress                 string  ,
     CamZone                    string  ,
     CamContactName             string  ,
     CamEmailID                 string  ,
     CamPhone                   string  ,
     CamNotloc                  string  ,
     CamNotZon                  string  ,
     CamNotContctName           string  ,
     CamNotPhone                string  ,
     CamNotEmailID              string  ,
     CamSMSNot                  string

     FROM @in
//     USING Extractors.Csv(skipFirstNRows:1);
USING Extractors.Csv();


OUTPUT @CustData   
    TO @out
      USING Outputters.Csv();

错误

输入包含 1 列 - OutletLandmark - 3 列的数据:

  • 附近,论坛报,CHOWNK。

这导致列数不匹配。输入数据需要固定。