如何使用配置單元腳本訪問dynamoDb中blob的個人元素？

Question

我正在使用AWS Data Pipeline中的配置單元腳本將數據從DynamoDB傳輸到S3。我使用的是這樣的腳本：

創建存儲BY 「org.apache.hadoop外部表dynamodb_table（屬性STRING，EMAIL STRING，.............）。 hive.dynamodb.DynamoDBStorageHandler'TBLPROPERTIES （「dynamodb.table.name」=「$ {DYNAMODB_INPUT_TABLE}」， 「dynamodb.column.mapping」= 「PROPERTIES：Properties，EMAIL：EmailId ....」）; CREATE EXTERNAL TABLE s3_table（ PROPERTIES STRING， EMAIL STRING， ...... ）

行格式分隔字段TERMINATED BY TERMINATED BY '\ n'

LOCATION' '\ T' LINES $ {S3_OUTPUT_BUCKET}「;

INSERT OVERWRITE TABLE s3_table SELECT * FROM dynamodb_table;

在DyanmoDB表中的屬性欄是這樣

屬性：字符串 ：{\ 「協議\」：空，\ 「MinType \」：空，\ 「打折\」：空}

它是它包含多個屬性。我希望屬性中的每個屬性都作爲一個單獨的列（不只是單個列中的一個字符串）。我想在此架構

輸出交易MinType折扣EMAIL

我怎樣才能做到這一點？

Answer 1

您的屬性列是否爲正確的JSON格式？如果是這樣，它看起來像你可以 - https://cwiki.apache.org/confluence/display/Hive/LanguageManual+UDF#LanguageManualUDF-get_json_object