Google Cloud Function WHERE 查询过滤器不起作用

Question

我正在努力使用更新集合组“place_users”上的“存在”属性的云功能。

我的查询没有按“存在”== true 过滤条目。它曾经在客户端工作，但我将它切换到云功能，它不再过滤。所有文件都被退回。

exports.updatePoiPresence = functions.https.onCall((data: any, context: any) => {

    return new Promise((resolve, reject) => {

        return store.collectionGroup("place_users",
                (ref: any) => ref
                .where("user_id", "==", context.auth.uid)
                .where("day_stamp", "<", data.start_of_day / 1000)
                .where("presence", "==", true))
            .get()
            .then(
                (q_snapshot: any) => {

                    return q_snapshot.forEach((snapshot: any) => {
                        functions.logger.log("no docs value data fct:", snapshot.data())


                        snapshot.ref.update({
                                presence: false
                            })
                            .then((a: any) => {
                                resolve("ok");
                            })
                            .catch((error: any) => {
                                functions.logger.log("error survenue", error);
                                reject("Rejet pas identifie")
                            })
                    });


                })
    });
});

我为该 collectionGroup 创建了一系列索引： （我不知道在什么情况下使用哪个，因为我一直通过控制台单击索引创建向导，而没有考虑它们的用途。

Answer 1

您似乎错误地使用以下方式查询数据库：

    return store.collectionGroup("place_users",
        (ref: any) => ref
            .where("user_id", "==", context.auth.uid)
            .where("day_stamp", "<", data.start_of_day / 1000)
            .where("presence", "==", true))
        .get()

collectionGroup() 方法只接受一个参数。你应该这样做：

    return store.collectionGroup("place_users")
            .where("user_id", "==", context.auth.uid)
            .where("day_stamp", "<", data.start_of_day / 1000)
            .where("presence", "==", true))
        .get()

---

此外，请注意 Firebase 异步方法返回承诺。您无需将代码包装在 return new Promise(); 中。

以下应该可以解决问题。

const store = admin.firestore();

exports.updatePoiPresence = functions.https.onCall((data: any, context: any) => {

    return store.collectionGroup("place_users")
        .where("user_id", "==", context.auth.uid)
        .where("day_stamp", "<", data.start_of_day / 1000)
        .where("presence", "==", true)
        .get()
        .then((q_snapshot: any) => {
            const promises = [];
            q_snapshot.forEach((snapshot: any) => {
                functions.logger.log("no docs value data fct:", snapshot.data())
                promises.push(snapshot.ref.update({ presence: false }));
            });
            return Promise.all(promises);
        })
        .catch((error: any) => {
            functions.logger.log("error survenue", error);
            return null;
        })

});

请注意，我们使用Promise.all()，因为我们对数据库并行执行多个异步操作（使用返回承诺的update() 方法，请参阅doc）。

---

你也可以看看"Cloud Functions for Firebase: getting started with TypeScript"官方的文章。特别要注意 Cloud Functions 的导出方式，与 JavaScript (exports. -> export const) 进行比较。