Firestore Enterprise edition with MongoDB compatibility is now available! Learn more.

Эта страница переведена с помощью Cloud Translation API.

Распределенные счетчики

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

В Cloud Firestore невозможно обновлять один документ с неограниченной частотой. Если у вас есть счётчик, основанный на одном документе, и его значения увеличиваются достаточно часто, в конечном итоге возникнут конфликты при обновлениях документа. См. раздел «Обновления одного документа» .

Решение: Распределенные счетчики

Для поддержки более частых обновлений счётчика создайте распределённый счётчик. Каждый счётчик представляет собой документ с подколлекцией «шардов», а значение счётчика представляет собой сумму значений этих шардов.

Пропускная способность записи линейно увеличивается с количеством шардов, поэтому распределенный счетчик с 10 шардами может обрабатывать в 10 раз больше записей, чем традиционный счетчик.

Интернет

// counters/${ID}
{
  "num_shards": NUM_SHARDS,
  "shards": [subcollection]
}

// counters/${ID}/shards/${NUM}
{
  "count": 123
}

Быстрый

Примечание: этот продукт недоступен на устройствах watchOS и App Clip.

// counters/${ID}
struct Counter {
  let numShards: Int

  init(numShards: Int) {
    self.numShards = numShards
  }
}

// counters/${ID}/shards/${NUM}
struct Shard {
  let count: Int

  init(count: Int) {
    self.count = count
  }
}SolutionCountersViewController.swift

Objective-C

Примечание: этот продукт недоступен на устройствах watchOS и App Clip.

// counters/${ID}
@interface FIRCounter : NSObject
@property (nonatomic, readonly) NSInteger shardCount;
@end

@implementation FIRCounter
- (instancetype)initWithShardCount:(NSInteger)shardCount {
  self = [super init];
  if (self != nil) {
    _shardCount = shardCount;
  }
  return self;
}
@end

// counters/${ID}/shards/${NUM}
@interface FIRShard : NSObject
@property (nonatomic, readonly) NSInteger count;
@end

@implementation FIRShard
- (instancetype)initWithCount:(NSInteger)count {
  self = [super init];
  if (self != nil) {
    _count = count;
  }
  return self;
}
@endFIRSolutionCountersViewController.m

Kotlin

// counters/${ID}
data class Counter(var numShards: Int)

// counters/${ID}/shards/${NUM}
data class Shard(var count: Int)SolutionCounters.kt

Java

// counters/${ID}
public class Counter {
    int numShards;

    public Counter(int numShards) {
        this.numShards = numShards;
    }
}

// counters/${ID}/shards/${NUM}
public class Shard {
    int count;

    public Shard(int count) {
        this.count = count;
    }
}SolutionCounters.java

Питон

import random

from google.cloud import firestore


class Shard:
    """
    A shard is a distributed counter. Each shard can support being incremented
    once per second. Multiple shards are needed within a Counter to allow
    more frequent incrementing.
    """

    def __init__(self):
        self._count = 0

    def to_dict(self):
        return {"count": self._count}


class Counter:
    """
    A counter stores a collection of shards which are
    summed to return a total count. This allows for more
    frequent incrementing than a single document.
    """

    def __init__(self, num_shards):
        self._num_shards = num_shards
distributed_counters.py

Python

import random

from google.cloud import firestore


class Shard:
    """
    A shard is a distributed counter. Each shard can support being incremented
    once per second. Multiple shards are needed within a Counter to allow
    more frequent incrementing.
    """

    def __init__(self):
        self._count = 0

    def to_dict(self):
        return {"count": self._count}


class Counter:
    """
    A counter stores a collection of shards which are
    summed to return a total count. This allows for more
    frequent incrementing than a single document.
    """

    def __init__(self, num_shards):
        self._num_shards = num_shards
distributed_counters.py

Node.js

Неприменимо, см. фрагмент приращения счетчика ниже.

Идти

import (
	"context"
	"fmt"
	"math/rand"
	"strconv"

	"cloud.google.com/go/firestore"
	"google.golang.org/api/iterator"
)

// Counter is a collection of documents (shards)
// to realize counter with high frequency.
type Counter struct {
	numShards int
}

// Shard is a single counter, which is used in a group
// of other shards within Counter.
type Shard struct {
	Count int
}
solution_counters.go

PHP

Неприменимо, см. фрагмент инициализации счетчика ниже.

С#

/// <summary>
/// Shard is a document that contains the count.
/// </summary>
[FirestoreData]
public class Shard
{
    [FirestoreProperty(name: "count")]
    public int Count { get; set; }
}Program.cs

Следующий код инициализирует распределенный счетчик:

Интернет

function createCounter(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++) {
        const shardRef = ref.collection('shards').doc(i.toString());
        batch.set(shardRef, { count: 0 });
    }

    // Commit the write batch
    return batch.commit();
}test.solution-counters.js

Быстрый

Примечание: этот продукт недоступен на устройствах watchOS и App Clip.

func createCounter(ref: DocumentReference, numShards: Int) async {
  do {
    try await ref.setData(["numShards": numShards])
    for i in 0...numShards {
      try await ref.collection("shards").document(String(i)).setData(["count": 0])
    }
  } catch {
    // ...
  }
}SolutionCountersViewController.swift

Objective-C

}

# # Примечание: этот продукт недоступен на устройствах watchOS и App Clip.

- (void)createCounterAtReference:(FIRDocumentReference *)reference shardCount:(NSInteger)shardCount { [reference setData:@{ @"numShards": @(shardCount) } completion:^(NSError * _Nullable error) { for (NSInteger i = 0; i < shardCount; i++) { NSString *shardName = [NSString stringWithFormat:@"%ld", (long)shardCount]; [[[reference collectionWithPath:@"shards"] documentWithPath:shardName] setData:@{ @"count": @(0) }]; } }]; class="devsite-github-link nocode no-select">FIRSolutionCountersViewController.m

Kotlin

fun createCounter(ref: DocumentReference, numShards: Int): Task<Void> { // Initialize the counter document, then initialize each shard. return ref.set(Counter(numShards)) .continueWithTask { task -> if (!task.isSuccessful) { throw task.exception!! } val tasks = arrayListOf<Task<Void>>() // Initialize each shard with count=0 for (i in 0 until numShards) { val makeShard = ref.collection("shards") .document(i.toString()) .set(Shard(0)) tasks.add(makeShard) } Tasks.whenAll(tasks) } class="devsite-github-link nocode no-select">SolutionCounters.kt

Распределенные счетчики Оптимизируйте свои подборки Сохраняйте и классифицируйте контент в соответствии со своими настройками.

Решение: Распределенные счетчики

Интернет

Быстрый

Objective-C

Kotlin

Java

Питон

Python

Node.js

Идти

PHP

С#

Интернет

Быстрый

Objective-C

Kotlin

Java

Питон

Python

Node.js

Идти

PHP

С#

Руби

Интернет

Быстрый

Objective-C

Kotlin

Java

Питон

Python

Node.js

Идти

PHP

С#

Руби

Интернет

Быстрый

Objective-C

Kotlin

Java

Питон

Python

Node.js

Идти

PHP

С#

Руби

Ограничения

Распределенные счетчики