2015-06-08 38 views
0

我設置數據管道以將數據導入dynamodb數據庫。 我創建了一個腳本,它將匹配dynamodb導出的語法。 下面是示例輸出,使用數據管道將數據導入dynamodb時出現異常

DateAdded^C { 「S」: 「2009-11-10T18:19:00-07:00」} ^盆地^ C { 「S」: 「B001AMUFSE」} 添加日期^ C {「s」:「2009-11-10T18:19:00-07:00」}^BASIN^C {「s」:「B0013IWYHU」} 已加入日期^ C {「s」:「2009- 11-10T18:17:00-07:00 「} ^盆地^ C {」 S 「:」 B000P62ND6" }

當我養活這個文件數據管道我收到提示

org.apache.hadoop.hive.ql.metadata.HiveException:Hive運行時錯誤或處理row {「item」:{「DateAdded^C {\」s \「:\」2009-11-10T18:19:00-07:00 \「}^BASIN^C {\」s \「: \ 「B001AMUFSE \」}「:空}}

有什麼不對與輸入格式,這裏是不是我的腳本線,轉換成上述synatx

line = 'DateAdded\x03{o}"s":"{}"{c}\x02ASIN\x03{o}"s":"{}"{c}\n'.format(record.date_added, record.asin, o = '{', c = '}') 

回答

0

得到了答案,\對於新行,我需要使用\ x0A作爲換行符。

相關問題