为何cURL可调用KSQLDB REST Proxy，而httpx/requests无法正常工作？

核心原因分析 #

你的脚本无响应，本质是httpx与curl在流式响应处理、HTTP版本适配、请求头部配置上的默认行为差异：

• 流式处理缺失：KSQLDB的Push Query是持续流式返回数据，curl默认会逐行输出响应；但httpx默认的get()/post()方法会等待完整响应返回才继续执行，而Push Query永远不会结束，导致脚本一直挂起。
• HTTP版本不匹配：/query-stream接口要求使用HTTP/2，httpx默认未启用HTTP/2，需要显式配置。
• 请求头部不全：curl会自动补充必要的请求头部，而httpx需要手动指定KSQLDB要求的Content-Type和Accept头部。

可行的Python示例代码 #

方式1：HTTP/1.1调用/query接口（流式处理） #

import httpx

def run_push_query():
    ksqldb_url = "http://localhost:8088/query"
    query = "SELECT * FROM YOUR_TABLE EMIT CHANGES;"
    
    headers = {
        "Content-Type": "application/vnd.ksql.v1+json",
        "Accept": "application/json"
    }
    
    payload = {
        "ksql": query,
        "streamsProperties": {
            "ksql.streams.auto.offset.reset": "earliest"
        }
    }
    
    # 启用流式请求，逐行读取响应
    with httpx.Client(http2=False) as client:
        with client.post(ksqldb_url, json=payload, headers=headers, stream=True) as response:
            response.raise_for_status()
            # 逐行处理流式返回的JSON数据
            for line in response.iter_lines():
                if line:
                    print(line)

if __name__ == "__main__":
    run_push_query()

方式2：HTTP/2调用/query-stream接口 #

import httpx

def run_push_query_http2():
    ksqldb_url = "http://localhost:8088/query-stream"
    query = "SELECT * FROM YOUR_TABLE EMIT CHANGES;"
    
    headers = {
        "Content-Type": "application/vnd.ksql.v1+json",
        "Accept": "application/json"
    }
    
    payload = {
        "ksql": query,
        "streamsProperties": {
            "ksql.streams.auto.offset.reset": "earliest"
        }
    }
    
    # 显式启用HTTP/2适配/query-stream接口
    with httpx.Client(http2=True) as client:
        with client.post(ksqldb_url, json=payload, headers=headers, stream=True) as response:
            response.raise_for_status()
            for line in response.iter_lines():
                if line:
                    print(line)

if __name__ == "__main__":
    run_push_query_http2()

关键注意事项 #

• 必须设置stream=True，告知httpx以流式方式处理响应，而非等待完整响应。
• 严格指定Content-Type为application/vnd.ksql.v1+json，Accept为application/json，这是KSQLDB API的强制要求。
• 使用/query-stream时，必须通过http2=True启用HTTP/2支持。
• 用iter_lines()逐行解析响应，因为KSQLDB的Push Query会每行返回一个独立的JSON对象。

内容的提问来源于stack exchange，提问作者feder