如何在Firebase实时数据库创建事件触发的Cloud Function中写入数据？

在你的场景下，有两种无需手动配置连接参数的直接方式可以实现写入另一个数据库节点的需求：

1. 全局初始化firebase_admin SDK（官方推荐） #

Cloud Function的Python环境支持全局初始化SDK，冷启动时仅执行一次初始化，后续调用复用实例，完全不需要重复设置连接参数。利用默认应用凭据（Application Default Credentials），Cloud Function会自动使用自身的服务账号权限，只要该账号拥有实时数据库的写入权限即可。

代码示例：

import os
import functions_framework
import numpy
import uuid
import firebase_admin
from firebase_admin import db

@functions_framework.cloud_event
def manage_tags(cloud_event):
    data = cloud_event.data
    database_url = data["databaseURL"]

    # 仅在首次调用（冷启动）时初始化SDK
    if not firebase_admin._apps:
        cred = firebase_admin.credentials.ApplicationDefault()
        firebase_admin.initialize_app(cred, {
            'databaseURL': database_url
        })

    # 写入数据到目标节点
    target_ref = db.reference('your-target-node')
    # 示例：推送新数据节点
    new_entry_ref = target_ref.push({
        'content': 'your-data-content',
        'uuid': str(uuid.uuid4())
    })
    print(f"写入成功，节点路径：{new_entry_ref.path}")

    # 你的业务逻辑代码
    [...]

2. 直接调用Firebase实时数据库REST API #

如果不想依赖firebase_admin SDK，可以利用事件中携带的databaseURL，结合Cloud Function默认服务账号的访问令牌，直接调用REST API完成写入操作。

代码示例：

import os
import functions_framework
import numpy
import uuid
import requests
from google.auth import default
from google.auth.transport.requests import Request

@functions_framework.cloud_event
def manage_tags(cloud_event):
    data = cloud_event.data
    database_url = data["databaseURL"]
    target_node = "your-target-node"

    # 获取默认服务账号的访问令牌
    creds, _ = default()
    creds.refresh(Request())
    auth_token = creds.token

    # 构建REST API请求地址
    api_url = f"{database_url}/{target_node}.json"

    # 准备写入的数据
    payload = {
        'content': 'your-data-content',
        'uuid': str(uuid.uuid4())
    }

    # 发送POST请求推送新数据（如需替换节点则用PUT）
    response = requests.post(
        api_url,
        json=payload,
        headers={"Authorization": f"Bearer {auth_token}"}
    )

    if response.ok:
        print(f"数据写入成功，响应：{response.json()}")
    else:
        print(f"写入失败，状态码：{response.status_code}，错误信息：{response.text}")

    # 你的业务逻辑代码
    [...]

注意事项 #

• 两种方式都需要确保Cloud Function的服务账号拥有Firebase实时数据库的写入权限，可在Firebase控制台的数据库规则或IAM权限中配置。
• 使用SDK方式时，无需手动管理凭据，初始化逻辑会自动处理；使用REST方式时，需要在requirements.txt中添加requests依赖。

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