如何在Django Admin中监听Firebase实时数据库并实现桌面通知

一、现有监听代码的优化 #

针对你当前代码启动时重复显示旧通知、获取全量数据的问题，可从以下方向优化：

1. 仅监听新增通知节点 #

Firebase实时数据库的listen方法默认会触发初始全量同步，你可以通过过滤节点路径和记录已处理ID来只处理新增数据：

import firebase_admin
from firebase_admin import credentials, db
import notification

cred = credentials.Certificate('my-credentials')
firebase_app = firebase_admin.initialize_app(cred, {
    'databaseURL': 'my-project-firebase-link'
})

notification_ref = db.reference('notifications')
processed_ids = set()

# 初始化时先记录已存在的通知ID，避免启动时重复触发
existing_notifications = notification_ref.get(shallow=True)
if existing_notifications:
    processed_ids.update(existing_notifications.keys())

def listen_to_notification_changes(event):
    # 仅处理新增的子节点（排除初始全量同步的根节点事件）
    if event.path != '/':
        notification_id = event.path.strip('/')
        if notification_id in processed_ids:
            return
        processed_ids.add(notification_id)
        
        latest_notification = event.data
        if isinstance(latest_notification, dict):  
            title = latest_notification.get("title", "")
            subtitle = latest_notification.get("subtitle", "")
        else:
            title = ""  
            subtitle = ""  

        notification.notify(
            title=title,
            message=subtitle,    
        )

notification_ref.listen(listen_to_notification_changes)

核心逻辑：新增通知时event.path会指向具体的通知ID节点，而非根节点/；用集合记录已处理的ID，避免重复展示历史通知。

2. 优化数据存储结构 #

如果你的通知按时间戳生成节点键名（比如1718000000），可以直接利用Firebase的child_added事件特性，无需遍历全量数据：

def listen_to_notification_changes(event):
    # 仅处理新增节点，event.data就是单条通知数据
    if event.path != '/':
        title = event.data.get("title", "")
        subtitle = event.data.get("subtitle", "")
        notification.notify(title=title, message=subtitle)

notification_ref.listen(listen_to_notification_changes)

原理：Firebase监听子节点新增时，会自动传递单条数据，无需从全量数据中提取最新项。

二、Flutter、Firebase与Django的集成方案 #

除了实时数据库监听，还有更高效的集成方式：

1. 基于Firebase Cloud Messaging（FCM）的直接推送 #

• Flutter端：使用firebase_messaging插件接收FCM通知，支持移动端和桌面端（Windows/macOS/Linux）。
• Django端：通过Firebase Admin SDK发送FCM通知到指定设备（包括Django Admin所在的桌面客户端）。
• 优势：无需自行监听数据库，FCM负责实时推送与离线缓存，稳定性更高。

2. Firebase Functions联动Django API #

• 当Flutter向Firebase写入通知时，触发Firebase Cloud Functions，直接调用Django的后端API，通知Django Admin展示桌面通知。
• 替代思路：Django Admin定时调用Firebase Admin SDK，按时间戳拉取最新通知，避免持续监听。

三、替代方案 #

如果Firebase实时数据库监听不符合需求，可考虑以下方案：

1. Django Channels实现WebSocket通信 #

• 在Django中配置Channels，建立WebSocket连接，Flutter端直接通过WebSocket向Django Admin推送通知，无需经过Firebase。
• 适合仅需Django与Flutter内部实时通信的场景。

2. 第三方消息队列（Redis/RabbitMQ） #

• Flutter将通知发送到消息队列，Django Admin作为消费者监听队列，获取最新通知后展示桌面通知。
• 优势：比Firebase更灵活，适配复杂业务逻辑。

3. 定时拉取最新通知 #

• Django Admin定时执行任务，调用Firebase Admin SDK查询按时间戳排序的第一条通知，无需实时监听。
• 实现简单，适合对实时性要求不高的场景。

内容的提问来源于stack exchange，提问作者Franco Ribarov