Python版Google Cloud Function线程发HTTPS请求遇SSL错误求助

你遇到的SSL错误核心原因是Google Cloud Function（GCF）的生命周期机制：一旦你的函数返回响应，GCF会立刻启动进程资源回收，包括你后台启动的线程——线程里的requests.post还没完成SSL握手或数据传输，连接就被强制切断，才会抛出SSLZeroReturnError。

推荐解决方案：改用Google Cloud Tasks异步处理 #

这是GCF官方认可的后台任务方案，完全适配GCF的运行模型，不会出现线程被强制终止的问题，同时能保证响应速度（函数只需提交任务即可返回）。

实现步骤与示例代码 #

1. 先在Google Cloud控制台创建一个Cloud Tasks队列
2. 在GCF中引入Cloud Tasks客户端，将转发请求的逻辑提交到队列：

from google.cloud import tasks_v2
import json

@functions_framework.http
def my_function(request):
    d = process_content(request.data)
    client = tasks_v2.CloudTasksClient()
    # 替换为你的项目ID、区域、队列名称
    parent = client.queue_path("your-project-id", "your-region", "your-queue-name")
    
    for listener in listeners:
        task = {
            "http_request": {
                "http_method": tasks_v2.HttpMethod.POST,
                "url": listener,
                "headers": {"Content-Type": "application/json"},
                "body": json.dumps(d).encode()
            }
        }
        client.create_task(request={"parent": parent, "task": task})
    
    return "Success", 200

Cloud Tasks会负责异步调用各个监听器的端点，即使GCF函数已经结束，任务依然会正常执行。

不推荐的临时Workaround（仅用于测试） #

如果暂时不想接入Cloud Tasks，可以尝试给线程留极短的启动时间，但这会轻微增加响应时间，且依然存在线程被终止的风险：

import time
from threading import Thread
import requests

@functions_framework.http
def my_function(request):
    d = process_content(request.data)
    threads = []
    for listener in listeners:
        t = Thread(target=requests.post, args=(listener,), kwargs={"json" : d})
        t.start()
        threads.append(t)
    # 给线程留极短时间启动请求（不等待完成）
    time.sleep(0.1)
    return "Success", 200

关于verify=False的说明 #

你提到的verify=False是用来跳过SSL证书验证的，但你的错误是连接被强制关闭，而非证书信任问题，所以这个参数解决不了根本问题，反而会引入安全风险，完全没必要使用。

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