Firebase中如何指定Cloud Tasks的触发区域？

使用Firebase Cloud Tasks处理后台任务时，默认GCP资源位置是us-central，但我的Cloud Task队列实际在europe-west1。触发函数时系统会去us-central找队列，导致找不到目标队列，该怎么配置才能让函数指向europe-west1的队列？

代码示例：

exports.tasks = functions
    .region("us-central1")
    .tasks.taskQueue({
        retryConfig: {
            maxAttempts: 5,
            minBackoffSeconds: 60,
        },
        rateLimits: {
            maxConcurrentDispatches: 6,
        },
    }).onDispatch(async (data) => {
        const { handletasks } = require("./modules/taskHandler");

        return await handletasks(data);
    });

const { getFunctions } = require('firebase-admin/functions');

const enqueueTasks = async (type, data) => {

    const queue = getFunctions().taskQueue("tasks");

    const enqueues = [];

    const scheduleDelaySeconds = 60;

    enqueues.push(
        queue.enqueue({
            type,
            data
        },
            {
                scheduleDelaySeconds,
                dispatchDeadlineSeconds: 60 * 5 // 5 minutes
            },
        ),
    );

    await Promise.all(enqueues);
}

要让函数正确找到europe-west1的队列，需要在任务队列定义和入队操作两处都指定队列的区域：

1. 定义任务队列时声明队列位置 #

在tasks.taskQueue()的配置对象里添加location字段，明确指定队列所在的europe-west1区域：

exports.tasks = functions
    .region("us-central1") // 函数运行区域可以保留原设置，和队列区域无关
    .tasks.taskQueue({
        location: "europe-west1", // 关键：指定队列所在区域
        retryConfig: {
            maxAttempts: 5,
            minBackoffSeconds: 60,
        },
        rateLimits: {
            maxConcurrentDispatches: 6,
        },
    }).onDispatch(async (data) => {
        const { handletasks } = require("./modules/taskHandler");

        return await handletasks(data);
    });

2. 入队时指定队列区域 #

调用taskQueue()方法时，第二个参数传入区域配置，确保Admin SDK能定位到正确区域的队列：

const { getFunctions } = require('firebase-admin/functions');

const enqueueTasks = async (type, data) => {
    // 关键：第二个参数指定队列所在的europe-west1区域
    const queue = getFunctions().taskQueue("tasks", { location: "europe-west1" });

    const enqueues = [];
    const scheduleDelaySeconds = 60;

    enqueues.push(
        queue.enqueue({
            type,
            data
        },
            {
                scheduleDelaySeconds,
                dispatchDeadlineSeconds: 60 * 5 // 5 minutes
            },
        ),
    );

    await Promise.all(enqueues);
}

注意事项 #

• 函数运行区域和队列区域可以不同，两者是独立配置；
• 确认GCP的europe-west1区域中确实存在名为tasks的Cloud Tasks队列；
• 修改代码后需要重新部署Firebase函数，新配置才会生效。

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