我正在尝试指定数据格式和 HTTP 标头,以确保使用 Strimzi Kafka 将有效请求提交给 Kafka Bridge。
消息格式 使用 /topics 端点发送消息时,您在请求正文中的 records 参数中输入消息负载。
记录参数可以包含以下任何可选字段:
消息头
消息键
消息价值
**Python中的示例代码**
导入请求
headers = {'content-type': 'application/vnd.kafka.json.v2+json', }
数据='{“记录”:[{“key”:“key-1”,“value”:“value-1”},{“key”:“key-2”,“value”:“value-2” " } ] }'
response = requests.post('http://localhost:54304/topics/my-topic', headers=headers, data=data)
因此,我需要修改示例 JSON API 有效负载,使其与请求正文中 data = '{....}' 的数据格式相匹配。
示例 JSON API:http ://api.open-notify.org/astros.json
输出
{“消息”:“成功”,“数字”:11,“人”:[{“名称”:“迈克霍普金斯”,“工艺”:“ISS”},{“名称”:“维克多格洛弗”,“工艺”:“国际空间站”},{“名称”:“香农沃克”,“工艺”:“国际空间站”},{“名称”:“野口宗一”,“工艺”:“国际空间站”},{“名称” : "Mark Vande Hei", "craft": "ISS" }, { "name": "Oleg Novitskiy", "craft": "ISS" }, { "name": "Pyotr Dubrov", "craft": " ISS" }, { "name": "Thomas Pesquet", "craft": "ISS" }, { "name": "Megan McArthur", "craft": "ISS" },{“名称”:“Shane Kimbrough”,“工艺”:“ISS”},{“名称”:“Akihiko Hoshide”,“工艺”:“ISS”}]}
请问如何将 JSON 有效负载格式化为用于生成消息的数据结构?