将Firestore数据库中存储的实时数据发送至Telegram是否可行？

结论 #

完全可以实现将Firestore中的实时数据发送到Telegram，核心实现逻辑是通过Firebase云函数监听Firestore的集合/文档变更事件，触发后调用Telegram Bot API完成消息推送即可。

核心实现步骤 #

• 首先创建Telegram Bot：通过Telegram官方Bot账号@BotFather申请创建Bot，获取到Bot API Token，同时获取需要接收消息的目标聊天ID（支持私人账号、群组、频道三种类型）
• 在你的Firebase项目中开启云函数功能，根据业务需求选择对应的Firestore触发器：可选onCreate（新文档创建时触发）、onUpdate（文档内容更新时触发）、onDelete（文档删除时触发）、onWrite（所有文档变更场景都触发）
• 在云函数的业务逻辑中，读取发生变更的Firestore数据内容，拼装为消息格式后调用Telegram Bot的sendMessage接口发送即可

简化实现代码（Node.js 云函数） #

const functions = require("firebase-functions");
const axios = require("axios");

// 替换为你自己申请的Bot Token和目标聊天ID
const TELEGRAM_BOT_TOKEN = "你的Telegram Bot Token";
const TARGET_CHAT_ID = "接收消息的聊天ID";

// 示例：监听example_collection集合下的新文档创建事件
exports.syncFirestoreToTelegram = functions.firestore
  .document("example_collection/{documentId}")
  .onCreate(async (snapshot, context) => {
    // 获取变更的Firestore文档数据
    const changedData = snapshot.data();
    // 拼装要发送的消息内容
    const sendContent = `Firestore有新数据同步：
文档ID：${context.params.documentId}
数据内容：${JSON.stringify(changedData, null, 2)}`;
    try {
      // 调用Telegram接口发送消息
      await axios.post(`https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendMessage`, {
        chat_id: TARGET_CHAT_ID,
        text: sendContent
      });
      return { code: 0, msg: "发送成功" };
    } catch (error) {
      console.error("消息推送失败：", error);
      return { code: 1, msg: "发送失败", error: error };
    }
  });

注意事项 #

• 部署云函数时需要选择可正常访问Telegram服务的区域，不要使用国内云区域
• 如果需要发送结构化消息，可以使用Telegram支持的Markdown或HTML格式对内容进行渲染
• 可以在云函数中添加过滤逻辑，只将符合业务规则的Firestore数据推送到Telegram，避免无效消息干扰

内容的提问来源于stack exchange，提问作者Javier Wong