1

我正在尝试指定数据格式和 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 有效负载格式化为用于生成消息的数据结构?

4

0 回答 0