如何使用Cloud Functions解析XML Feed并存储到Firestore？

要处理XML Feed并将数据存入Firestore，我们可以使用xml2js库将XML字符串转换为可操作的JSON对象，再结合你已熟悉的axios和Firebase Admin SDK完成存储。以下是完整实现步骤：

1. 安装依赖 #

在你的Cloud Functions项目目录下，运行命令安装XML解析库：

npm install xml2js

2. 编写XML处理的Cloud Function #

基于你现有的代码风格，新增XML解析与存储的函数（同时保留你已完成的JSON API处理函数）：

const functions = require("firebase-functions");
const axios = require("axios");
const admin = require("firebase-admin");
// 引入xml2js的Promise风格解析方法
const { parseStringPromise } = require("xml2js");

// 初始化Firebase Admin（如果你的现有代码未初始化，需添加此行）
admin.initializeApp();

// --- 你已完成的JSON API处理函数 ---
const api_token = "XXXXXXX";
const includes = "XXXXXX";
const url = "https://XXXXXXXXXXXXXX.com/?api_token=" + api_token + includes;

exports.allLeagues = functions.region('europe-west1').https.onRequest(async (req, res) => {
    try {
        let response = await axios.get(url);
        var data = response.data.data;
            
            for (let leagueData of data) {
                await admin.firestore().collection("leagues").doc(leagueData.id.toString()).collection("all_data").doc(leagueData.id.toString()).set({
                    id : leagueData.id,
                    name : leagueData.name,
                    logo_path : leagueData.logo_path,
                    is_cup : leagueData.is_cup
                });
            }
            console.log("Table complete...");

        console.log("successful");
        return res.status(200).json({ message: "successful" });
    } catch(error) {
        console.log("Error encountered: "+error);
        return res.status(500).json({ error });
    }
});

// --- 新增的XML Feed解析与存储函数 ---
const xmlFeedUrl = "https://www.feedforall.com/sample.xml";

exports.parseXmlFeed = functions.region('europe-west1').https.onRequest(async (req, res) => {
    try {
        // 1. 获取XML Feed原始内容
        const xmlResponse = await axios.get(xmlFeedUrl);
        const xmlString = xmlResponse.data;

        // 2. 将XML解析为JSON对象
        const parsedData = await parseStringPromise(xmlString, {
            explicitArray: false, // 单元素节点不转为数组，简化处理
            trim: true // 自动去除字符串首尾空格
        });

        // 3. 提取Feed中的条目（对应sample.xml里的<item>标签）
        const feedItems = parsedData.rss.channel.item;
        // 兼容单条目场景：如果只有一个item，转为数组统一遍历
        const itemsArray = Array.isArray(feedItems) ? feedItems : [feedItems];

        // 4. 遍历条目，存储到Firestore指定集合
        for (const item of itemsArray) {
            // 用条目的guid作为文档ID（避免重复写入），无guid则自动生成ID
            const docId = item.guid ? item.guid : admin.firestore().collection("feed_items").doc().id;
            await admin.firestore().collection("feed_items").doc(docId).set({
                title: item.title,
                link: item.link,
                description: item.description,
                pubDate: item.pubDate,
                category: item.category
                // 根据你的XML结构，添加更多需要存储的字段
            });
        }

        console.log("XML Feed条目已成功存储到Firestore");
        return res.status(200).json({ message: "XML Feed处理完成" });
    } catch (error) {
        console.log("处理XML Feed时出错: ", error);
        return res.status(500).json({ error: error.message });
    }
});

3. 部署函数 #

在终端运行以下命令部署新增的XML处理函数：

firebase deploy --only functions:parseXmlFeed

如果需要同时部署所有函数，运行：

firebase deploy --only functions

关键说明 #

• parseStringPromise是xml2js提供的Promise风格方法，适配async/await语法，避免回调嵌套
• 解析选项explicitArray和trim可根据你的XML结构调整，确保数据处理更顺畅
• 存储时使用条目的唯一标识（如guid）作为文档ID，可避免重复写入；若没有唯一标识，Firestore会自动生成随机ID
• 集合名称feed_items可根据你的需求修改为指定集合

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