Транзакции Firestore запускаются несколько раз, что приводит к неверным данным

Ребята наконец выяснили причину такого неожиданного поведения.

Firestore не подходит для обслуживания счетчиков, если ваше приложение будет интенсивно использовать трафик. Они упомянули об этом в своей документации. Они предлагают использовать распределенный счетчик.

Многие приложения реального времени имеют документы, которые действуют как счетчики. Например, вы можете подсчитывать «лайки» для публикации или «избранное» для определенного элемента.

В Cloud Firestore вы можете обновлять один документ примерно раз в секунду, что может быть слишком мало для некоторых приложений с высоким трафиком.

https://cloud.google.com/firestore/docs/solutions/counters

Меня не убедил такой подход, поскольку он слишком сложен для простого случая использования, когда я наткнулся на следующий блог

https://medium.com/evenbit/on-collision-course-with-cloud-firestore-7af26242bc2d

Эти ребята использовали комбинацию Firestore + Firebase, тем самым устранив свои слабые места.

Cloud Firestore удобно расположен рядом с базой данных Firebase Realtime, и они легко доступны для использования, смешивания и сопоставления в приложении. Вы можете свободно хранить данные в обоих местах для своего проекта, если это соответствует вашим потребностям.

Итак, почему бы не использовать базу данных Realtime для одной из ее сильных сторон: для управления быстрыми потоками данных от распределенных клиентов. Это единственная проблема, которая возникает при попытке агрегировать и подсчитывать данные в Firestore.

Неправильно говорить, что Firestore - это обновление базы данных Realtime (как она рекламируется), но это другая база данных с разными целями, и обе могут и должны сосуществовать в крупномасштабном приложении. Это моя мысль.

Это может иметь какое-то отношение к тому, что вы возвращаете из функции, так как у вас

return transaction.get(transRef).then(function (transDoc) { ... })

И затем еще один возврат внутри этого обратного вызова, но не return внутри самого внутреннего вложенного обратного вызова. Так что, возможно, он не выполняет transaction.update. Попробуйте удалить первые два return ключевых слова и добавить одно перед transaction.update:

firestore.runTransaction(function (transaction) {
        transaction.get(transRef).then(function (transDoc) {
            let currentLikesCount = transDoc.get("likesCount");
            if (event.data && !event.data.previous) {
                newLikesCount = currentLikesCount == 0 || isNaN(currentLikesCount) ? 1 : transDoc.get("likesCount") + 1;
            } else {
                newLikesCount = currentLikesCount == 0 || isNaN(currentLikesCount) ? 0 : transDoc.get("likesCount") - 1;
            }
            return transaction.update(transRef, { likesCount: newLikesCount });
        });
    });

Тайм-ауты

Прежде всего, проверьте журналы облачных функций, чтобы узнать, есть ли у вас timeout сообщения.

Function execution took 60087 ms, finished with status: 'timeout'

Если да, отсортируйте свою функцию так, чтобы она возвращала Promise.resolve(). И показывает

Function execution took 344 ms, finished with status: 'ok'

Идемпотентность

Во-вторых, напишите свои данные так, чтобы функция была идемпотентной. Когда ваша функция запускается, запишите значение в документ, который вы читаете. Затем вы можете проверить, существует ли это значение, прежде чем снова запускать функцию.

См. этот пример, чтобы убедиться, что функции запускаются только один раз.