pyspark foreach/foreachPartition发送http请求失败

from pyspark import SparkContext
import requests

def send_http_request(element):
    url = "https://example.com/api"
    headers = {"Content-Type": "application/json"}
    data = {"key": element}
    response = requests.post(url, headers=headers, json=data)
    if response.status_code != 200:
        print(f"Failed to send request for element: {element}")

sc = SparkContext("local", "HTTP Request Example")
data = sc.parallelize(["value1", "value2", "value3"])
data.foreach(send_http_request)

import requests
from requests.exceptions import RequestException

def send_http_request(element):
    url = "https://example.com/api"
    headers = {"Content-Type": "application/json"}
    data = {"key": element}
    try:
        response = requests.post(url, headers=headers, json=data)
        response.raise_for_status()  # 抛出 HTTP 错误
    except RequestException as e:
        print(f"Failed to send request for element: {element}. Error: {e}")