import requests

url = "http://192.168.7.229:8089/kafka_api/push_message?slot_id=p_00e43ftehhw"
body = {"user_id": "200", "action_type": "曝光", "item_id": "1541734",
        "session_id": "200@p_0iv2ilqfmp6\x0303e8aace6e8bbd70e00348744e6645bc\x03ep_0m2gwghvs37__热门物品",
        "action_value": "exposure", "ts": 0}
res = requests.post(url, json=body)
print(res.json())