Python Google Cloud Function Connection 由对等方重置

Question

详见此处：https://issuetracker.google.com/issues/113672049

在这里交叉发布：https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5879)

在 Python 中使用 Google Cloud Function 中的 Firebase Storage API 时出现连接重置错误。

部署的函数正在调用一个 blob-get 即

from firebase_admin import storage

def fn(request):
  bucket = 'my-firebase-bucket'
  path = '/thing'
  blob = storage.bucket(bucket).get_blob(path)

故障是间歇性的；该功能的成功率约为 90%。

函数部署后第一次调用似乎更有可能失败。

Answer 1

您可能想检查您正在创建的客户端数量。

尝试跨函数调用重用网络连接，如 在优化网络中描述。但是，请注意，连接 2分钟未使用的可能会被系统关闭，并且 进一步尝试使用关闭的连接将导致 “连接重置”错误。您的代码应该使用一个库 很好地处理关闭的连接，或者在使用时显式处理它们 低级网络结构。

https://cloud.google.com/functions/docs/concepts/exec#network

查看这个示例，他们只创建一次客户端并在函数中重用它：

import os
from google.cloud import pubsub_v1

# Create a global Pub/Sub client to avoid unneeded network activity
pubsub = pubsub_v1.PublisherClient()


def gcp_api_call(request):
    """
    HTTP Cloud Function that uses a cached client library instance to
    reduce the number of connections required per function invocation.
    Args:
        request (flask.Request): The request object.
    Returns:
        The response text, or any set of values that can be turned into a
        Response object using `make_response`
        <http://flask.pocoo.org/docs/1.0/api/#flask.Flask.make_response>.
    """

    project = os.getenv('GCP_PROJECT')
    request_json = request.get_json()

    topic_name = request_json['topic']
    topic_path = pubsub.topic_path(project, topic_name)

    # Process the request
    data = 'Test message'.encode('utf-8')
    pubsub.publish(topic_path, data=data)

    return '1 message published'

https://cloud.google.com/functions/docs/bestpractices/networking#accessing_google_apis

Answer 2

云函数是无状态的，但可以重用之前调用的全局状态。这在tips 和these docs 中有解释。

使用带重试的全局状态应该会给你一个更强大的功能：

from tenacity import retry, stop_after_attempt, wait_random
from firebase_admin import storage

@retry(stop=stop_after_attempt(3), wait=wait_random(min=1, max=2))
def get_bucket(storage):
    return storage.bucket('my-firebase-bucket')

@retry(stop=stop_after_attempt(3), wait=wait_random(min=1, max=2))
def get_blob(bucket, path):
    return bucket.get_blob(path)

bucket = get_bucket(storage)

def fn(request):
  path = '/thing'
  blob = get_blob(bucket, path)
  # etc..