U-SQL соединение не удалось - PullRequest
0 голосов
/ 27 ноября 2018

Привет. Я пытаюсь присоединиться, используя U-SQL, и три входных файла являются текстовыми, теперь я получаю сообщение об ошибке.Я новичок в этом.Когда я пытаюсь присоединиться, то выдает ошибку ниже.Я уже пробовал с этим: USING Extractors.Csv(encoding:System.Text.Encoding.GetEncoding("Windows-1252"));, но та же ошибка.Не могли бы вы помочь исправить ошибку:

{
    "errorCode": "2703",
    "message": "Error Id: E_CSC_USER_SYNTAXERROR, Error Message: syntax error. Expected one of: identifier quoted-identifier variable . Error Id: E_CSC_USER_RESERVEDKEYWORDASIDENTIFIER, Error Message: Reserved keyword FROM is used as an identifier.. Error Id: E_CSC_USER_SYNTAXERROR, Error Message: syntax error. Expected one of: '(' ANTISEMIJOIN BROADCASTLEFT BROADCASTRIGHT CROSS EXCEPT FULL FULLCROSS GROUP HASH HAVING INDEXLOOKUP INNER INTERSECT JOIN LEFT LOOP MERGE ON OPTION ORDER OUTER OUTER UNION PAIR PIVOT PRESORT RIGHT SAMPLE SEMIJOIN SERIAL UNION UNPIVOT WHERE WITH ';' ')' ',' . ",
    "failureType": "UserError",
    "target": "U-SQL1"
}

U-SQL Script

@customerData = EXTRACT 
    Customerid string,
    Name string,
    City string,
    State string,
    Country string,
    Account_Created string
FROM "/a_test/customer_data/[dbo].[customerData].txt"
USING Extractors.Csv(skipFirstNRows:1);


@productData = EXTRACT 
    Product string,
    Price string,
FROM "/a_test/product_data/[dbo].[productData].txt"
USING Extractors.Csv(skipFirstNRows:1);


@transactionData = EXTRACT 
    Transaction_date string,
    Product string,
    Payment_Type string,
    Customerid string,
    Name string,
    City string,
    Account_Created string,
    Last_Login string,
    Latitude string,
    Longitude string
FROM "/a_test/transaction_data/[dbo].[transactionData].txt"
USING Extractors.Csv(skipFirstNRows:1);

@result = 
SELECT 
    t.Customerid,
    t.Transaction_date,
    t.Product,
    t.Payment_Type,
    t.Name,
    t.City,
    c.State,
    c.Country,
    p.Price,
    t.Latitude,
    t.Longitude
  FROM @transactionData AS t
  INNER JOIN @productData AS p on t.Product = p.Product
  INNER JOIN @customerData AS c on t.Customerid = c.Customerid
  order by t.Customerid;

OUTPUT @result TO "/a_test/final_output"
USING Outputters.Csv();

1 Ответ

0 голосов
/ 27 ноября 2018
@productData = EXTRACT 
Product string,
Price string,
FROM "/a_test/product_data/[dbo].[productData].txt"
USING Extractors.Csv(skipFirstNRows:1);

У вас есть запятая (,) после столбца Строка цены, вы должны удалить его.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...