通过 Firehose 将地图数据放到 Athena答案

【问题标题】：Put Map data via Firehose to Athena通过 Firehose 将地图数据放到 Athena
【发布时间】：2019-11-18 21:57:07
【问题描述】：

我在 Athena 中有一个 Map 类型的专栏。我已将 Glue 中的模式定义为 Map 。

我已经定义了一个引用胶水模式并将其转换为镶木地板格式的 firehose 流。但是，我在发送数据时收到以下错误

The schema is invalid. Error parsing the schema: Error: type expected at the position 0 of 'MAP <STRING, INT>' but 'MAP ' is found.

我正在使用 boto3 firehose 客户端提交数据。

这是我尝试过的

records=[{'Data': '{"id": "aac4da11-d166-42bd-83db-c670f5b5676d", "createdutc": "2019-06-27 10:25:33","tokens": {"black": 1, "spot": 1, "joint": 1, "leg": 1, "due": 1, "itchinghow": 1, "reduce": 1}'}]

firehoseClient.put_record_batch(
    DeliveryStreamName='conversations-analysis',
    Records=records)

【问题讨论】：

遇到同样的问题，你能解决这个问题吗？
@Naveen nop 显然我不是要解决它

标签： boto3 amazon-athena amazon-kinesis-firehose

【解决方案1】：

显然，我能够解决它，用小写字母提及架构中的所有内容，您应该能够保存地图数据。例如地图而不是地图

【讨论】：

我遇到了同样的问题，但这似乎对我没有帮助。
对不起，从头开始，我刚刚意识到我的架构更新在第一次没有得到保存。我再次检查，确保我的模式的所有嵌套列类型都是小写的，并且它有效。感谢您的回答！顺便说一句，我在 AWS 论坛上找到了这篇相关帖子：forums.aws.amazon.com/thread.jspa?messageID=863428&tstart=0