我的应用程序将游戏结果存储在一个名为score的字段中,最终得分在-30到+30之间。如何查询所有游戏结果的总体平均值?

最佳答案

简单解决方案
如果您知道每秒最多写入一次游戏结果,则可以使用云功能更新单独的文档average/score。对于每一个游戏结果添加,如果文档不存在,则将一个字段称为count 1,并将字段称为“cc>”。如果文档确实存在,则将score添加到名为ccc>的字段中,并将分数添加到称为“cc>”的字段中。
现在,要查询平均分,只需阅读1并将count除以score
可扩展的解决方案
如果您怀疑或知道正在编写的游戏结果的数量将超过每秒一次,则需要应用简单解决方案的分布式计数器样式。
一般文档的数据模型将使用子集合,如下所示:

// average/score
{
  "num_shards": NUM_SHARDS,
  "shards": [subcollection]
}

// average/score/shards/${NUM}
{
  "count": 115,
  "score": 1472
}

要使更新代码更精简,可以首先使用以下命令初始化这些碎片:
// ref points to db.collection('average').doc('score')
function createAverageAggregate(ref, num_shards) {
    var batch = db.batch();

    // Initialize the counter document
    batch.set(ref, { num_shards: num_shards });

    // Initialize each shard with count=0
    for (let i = 0; i < num_shards; i++) {
        let shardRef = ref.collection('shards').doc(i.toString());
        batch.set(shardRef, { count: 0, count: 0 });
    }

    // Commit the write batch
    return batch.commit();
}

更新云函数中的平均聚合现在非常简单:
// ref points to db.collection('average').doc('score')
function updateAverage(db, ref, num_shards) {
    // Select a shard of the counter at random
    const shard_id = Math.floor(Math.random() * num_shards).toString();
    const shard_ref = ref.collection('shards').doc(shard_id);

    // Update count in a transaction
    return db.runTransaction(t => {
        return t.get(shard_ref).then(doc => {
            const new_count = doc.data().count + 1;
            const new_score = doc.data().score + 1;
            t.update(shard_ref, { count: new_count, score: new_score });
        });
    });
}

然后可以通过以下方法获得平均值:
// ref points to db.collection('average').doc('score')
function getAverage(ref) {
    // Sum the count and sum the score of each shard in the subcollection
    return ref.collection('shards').get().then(snapshot => {
        let total_count = 0;
        let total_score = 0;
        snapshot.forEach(doc => {
            total_count += doc.data().count;
            total_score += doc.data().score;
        });
        return total_score / total_count;
    });
}

在这个系统中可以达到的写入速率是每秒num_个碎片,因此请相应地计划。注意:你可以从小事做起,很容易增加碎片的数量。只需创建一个新版本的average/score来增加碎片的数量,方法是首先初始化新的碎片,然后更新num_shards设置以匹配。这应该由scorecount函数自动获取。

关于javascript - 查询集合中所有游戏结果的平均分数?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46549142/

10-12 05:30