无需凭据订阅 Firebase 项目事件：公共事件流指南

2024-03-26 00:45:35

如何在无需凭据的情况下订阅 Firebase 项目事件

引言

在构建分布式系统时，监控和及时响应事件至关重要。Firebase 提供了一种强大的事件系统，但前提是必须通过身份验证。对于没有登录凭据的情况，例如监控公共事件或在没有用户交互的情况下自动处理任务，本文提供了一种替代方法。本文将探讨如何使用公共事件流在无需凭据的情况下订阅 Firebase 项目事件。

公共事件流：无需身份验证的 Firebase 订阅

公共事件流是 Firebase 提供的一种公开事件集合，无需身份验证即可访问。这使得订阅公开事件成为可能，例如：

文档创建、更新或删除
集合中的查询结果变更
用户身份验证状态变更

步骤：

1. 获取公共事件流 URL

事件流 URL 如下所示：

https://firestore.googleapis.com/v1/projects/{project_id}/databases/(default)/documents

将 {project_id} 替换为您的 Firebase 项目 ID。

2. 创建请求正文

{
  "addTarget": {
    "query": {
      "all": true
    }
  }
}

此请求正文指定订阅所有文档事件。

3. 发送请求并获取订阅

使用 HTTP POST 请求发送请求并获取订阅 ID：

response = requests.post(event_stream_url, json=request_body)
if response.status_code == 200:
    subscription_id = response.headers["Location"].split("/")[-1]
    print("Subscription created: ", subscription_id)
else:
    raise Exception("Error creating subscription")

4. 处理事件流

使用 WebSocket 处理事件流：

def on_message(ws, message):
    print("Received message: ", message)

def on_error(ws, error):
    print("Received error: ", error)

def on_close(ws):
    print("Closed websocket")

websocket.enableTrace(True)
ws = websocket.WebSocketApp(f"{event_stream_url}/listen?subscription={subscription_id}",
                            on_message=on_message,
                            on_error=on_error,
                            on_close=on_close)
ws.run_forever()

示例代码

import requests
import websocket

def main():
    # Get project ID
    project_id = input("Enter Firebase project ID: ")

    # Get public event stream URL
    event_stream_url = f"https://firestore.googleapis.com/v1/projects/{project_id}/databases/(default)/documents"

    # Create request body
    request_body = {"addTarget": {"query": {"all": True}}}

    # Send request and get subscription
    response = requests.post(event_stream_url, json=request_body)
    if response.status_code == 200:
        subscription_id = response.headers["Location"].split("/")[-1]
        print("Subscription created: ", subscription_id)
    else:
        raise Exception("Error creating subscription")

    # Handle event stream
    def on_message(ws, message):
        print("Received message: ", message)

    def on_error(ws, error):
        print("Received error: ", error)

    def on_close(ws):
        print("Closed websocket")

    websocket.enableTrace(True)
    ws = websocket.WebSocketApp(f"{event_stream_url}/listen?subscription={subscription_id}",
                                on_message=on_message,
                                on_error=on_error,
                                on_close=on_close)
    ws.run_forever()

if __name__ == "__main__":
    main()