要對Kafka的JSON數據進行格式化,您可以使用Python的json庫。以下是一個簡單的示例,展示了如何將JSON字符串轉換為格式化的JSON字符串:
import json
# 原始的JSON字符串
raw_json = '{"name": "John", "age": 30, "city": "New York"}'
# 將JSON字符串轉換為Python字典對象
json_dict = json.loads(raw_json)
# 將Python字典對象轉換為格式化的JSON字符串
formatted_json = json.dumps(json_dict, indent=4, sort_keys=True)
# 打印格式化的JSON字符串
print(formatted_json)
輸出:
{
"age": 30,
"city": "New York",
"name": "John"
}
在這個示例中,我們首先使用json.loads()函數將原始的JSON字符串轉換為Python字典對象。然后,我們使用json.dumps()函數將字典對象轉換為一個格式化的JSON字符串。indent參數設置為4,表示使用4個空格進行縮進,sort_keys參數設置為True,表示按鍵名對字典進行排序。最后,我們打印格式化的JSON字符串。