如何放置映射类型的记录＆lt; string，array＆lt; string＆gt;＆gt;使用Firehose Python SDK胶水

Question

首先，我创建了一个简单的胶水模式和AWS交付流。使用简单类型（例如字符串或浮点），我可以通过使用以下python代码将记录放在交货流中，并看到它转换为S3上的镶木quet文件：

import json

import boto3

STREAM_NAME = 'TEST-STREAM'


def generate(stream_name, kinesis_client, output=True):
    count = 0
    total = 2000
    while count < total:
        count += 1
        response = kinesis_client.put_record(
            DeliveryStreamName=stream_name,
            Record={
                'Data': json.dumps({'id': '1234', 'value': 0.4})
            }
        )


if __name__ == '__main__':
    generate(STREAM_NAME, boto3.client('firehose', region_name='eu-west-1'))

但是，当我添加带有类型的字段时MAP＆lt; string，array＆lt; string＆gt;＆gt;访问我的架构，并与其他数据调用put_record api，发生以下错误：

response = kinesis_client.put_record(
            DeliveryStreamName=stream_name,
            Record={
                'Data': json.dumps({'id': '1234', 'value': 0.4, 'data':['a','b']})
            }
        )

错误：

Data does not match the schema. org.openx.data.jsonserde.json.JSONArray cannot be cast to org.openx.data.jsonserde.json.JSONObject

我缺少什么？