Firebase is back at Google I/O on May 10! Register now

اسناد را با جستارهای تجمیع شمارش کنید

با مجموعه‌ها، منظم بمانید ذخیره و دسته‌بندی محتوا براساس اولویت‌های شما.

یک کوئری تجمیع داده ها را از چندین ورودی فهرست پردازش می کند تا یک مقدار خلاصه واحد را برگرداند.

Cloud Firestore از کوئری جمع آوری count() پشتیبانی می کند. count() به شما امکان می دهد تعداد اسناد را در یک مجموعه یا پرس و جو تعیین کنید. سرور تعداد را محاسبه می کند، و تنها نتیجه، یک عدد صحیح را به برنامه شما ارسال می کند، در مقایسه با اجرای پرس و جوی کامل، در هر دو خواندن سند صورتحساب و بایت های منتقل شده صرفه جویی می کند.

جستارهای تجمیع بر پیکربندی فهرست موجودی که عبارت‌های جستجوی شما قبلاً استفاده می‌کردند متکی هستند و متناسب با تعداد ورودی‌های فهرست اسکن شده مقیاس می‌شوند. این به این معنی است که مجموعه‌های داده‌های کوچک تا متوسط ​​در 20-40 میلی‌ثانیه انجام می‌شوند، اگرچه تأخیر با تعداد موارد شمارش شده افزایش می‌یابد.

از تجمع count() استفاده کنید

به نمونه داده‌ای که در دریافت داده تنظیم کرده‌ایم مراجعه کنید.

انباشت count() زیر تعداد کل شهرهای مجموعه cities را برمی گرداند.

Web version 9

const coll = collection(db, "cities");
const snapshot = await getCountFromServer(coll);
console.log('count: ', snapshot.data().count);
سریع
توجه: این محصول در اهداف watchOS و App Clip موجود نیست.
let query = db.collection("cities")
let countQuery = query.count
do {
    let snapshot = try await countQuery.getAggregation(source: .server)
    print(snapshot.count)
} catch {
    print(error);
}
هدف-C
توجه: این محصول در اهداف watchOS و App Clip موجود نیست.
FIRCollectionReference *query = [self.db collectionWithPath:@"cities"];
[query.count aggregationWithSource:FIRAggregateSourceServer
                        completion:^(FIRAggregateQuerySnapshot *snapshot,
                                     NSError *error) {
    if (error != nil) {
        NSLog(@"Error fetching count: %@", error);
    } else {
        NSLog(@"Cities count: %@", snapshot.count);
    }
}];

Java

Query query = db.collection("cities");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(new OnCompleteListener<AggregateQuerySnapshot>() {
    @Override
    public void onComplete(@NonNull Task<AggregateQuerySnapshot> task) {
        if (task.isSuccessful()) {
            // Count fetched successfully
            AggregateQuerySnapshot snapshot = task.getResult();
            Log.d(TAG, "Count: " + snapshot.getCount());
        } else {
            Log.d(TAG, "Count failed: ", task.getException());
        }
    }
});

Kotlin+KTX

val query = db.collection("cities")
val countQuery = query.count()
countQuery.get(AggregateSource.SERVER).addOnCompleteListener { task ->
    if (task.isSuccessful) {
        // Count fetched successfully
        val snapshot = task.result
        Log.d(TAG, "Count: ${snapshot.count}")
    } else {
        Log.d(TAG, "Count failed: ", task.getException())
    }
}

Java

CollectionReference collection = db.collection("cities");
AggregateQuery countQuery = collection.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(task -> {
  if (task.isSuccessful()) {
    AggregateQuerySnapshot snapshot = task.getResult();
    Log.d(TAG, "Count: " + snapshot.getCount());
  } else {
    Log.d(TAG, "Count failed: ", task.getException());
  }
});
      
جاوا
CollectionReference collection = db.collection("cities");
AggregateQuerySnapshot snapshot = collection.count().get().get();
System.out.println("Count: " + snapshot.getCount());
      
Node.js
const collectionRef = db.collection('cities');
const snapshot = await collectionRef.count().get();
console.log(snapshot.data().count);
      

تجمیع count() هر فیلتری را در پرس و جو و هر بند limit را در نظر می گیرد. برای مثال، تجمیع زیر تعداد شهرهایی را که state برابر با CA است، برمی‌گرداند.

Web version 9

const coll = collection(db, "cities");
const q = query(coll, where("state", "==", "CA"));
const snapshot = await getCountFromServer(q);
console.log('count: ', snapshot.data().count);
سریع
توجه: این محصول در اهداف watchOS و App Clip موجود نیست.
let query = db.collection("cities").whereField("state", isEqualTo: "CA")
let countQuery = query.count
do {
    let snapshot = try await countQuery.getAggregation(source: .server)
    print(snapshot.count)
} catch {
    print(error);
}
هدف-C
توجه: این محصول در اهداف watchOS و App Clip موجود نیست.
FIRQuery *query =
    [[self.db collectionWithPath:@"cities"]
                 queryWhereField:@"state"
                       isEqualTo:@"CA"];
[query.count aggregationWithSource:FIRAggregateSourceServer
                        completion:^(FIRAggregateQuerySnapshot *snapshot,
                                      NSError *error) {
    if (error != nil) {
        NSLog(@"Error fetching count: %@", error);
    } else {
        NSLog(@"Cities count: %@", snapshot.count);
    }
}];

Java

Query query = db.collection("cities").whereEqualTo("state", "CA");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(new OnCompleteListener<AggregateQuerySnapshot>() {
    @Override
    public void onComplete(@NonNull Task<AggregateQuerySnapshot> task) {
        if (task.isSuccessful()) {
            // Count fetched successfully
            AggregateQuerySnapshot snapshot = task.getResult();
            Log.d(TAG, "Count: " + snapshot.getCount());
        } else {
            Log.d(TAG, "Count failed: ", task.getException());
        }
    }
});

Kotlin+KTX

val query = db.collection("cities").whereEqualTo("state", "CA")
val countQuery = query.count()
countQuery.get(AggregateSource.SERVER).addOnCompleteListener { task ->
    if (task.isSuccessful) {
        // Count fetched successfully
        val snapshot = task.result
        Log.d(TAG, "Count: ${snapshot.count}")
    } else {
        Log.d(TAG, "Count failed: ", task.getException())
    }
}

Java

CollectionReference collection = db.collection("cities");
Query query = collection.whereEqualTo("state", "CA");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(task -> {
  if (task.isSuccessful()) {
    AggregateQuerySnapshot snapshot = task.getResult();
    Log.d(TAG, "Count: " + snapshot.getCount());
  } else {
    Log.d(TAG, "Count failed: ", task.getException());
  }
});
      
جاوا
CollectionReference collection = db.collection("cities");
Query query = collection.whereEqualTo("state", "CA");
AggregateQuerySnapshot snapshot = query.count().get().get();
System.out.println("Count: " + snapshot.getCount());
      
Node.js
const collectionRef = db.collection('cities');
const query = collectionRef.where('state', '==', 'CA');
const snapshot = await query.count().get();
console.log(snapshot.data().count);
      

قوانین امنیتی Cloud Firestore در پرس‌و‌جوهای جمع‌آوری count() یکسان عمل می‌کنند که در جستارهای عادی که اسناد را برمی‌گردانند. به عبارت دیگر، اگر و تنها در صورتی که قوانین شما به کلاینت‌ها اجازه اجرای پرس‌وجوهای مجموعه یا گروه مجموعه خاصی را بدهد، کلاینت‌ها می‌توانند تجمیع count() را روی آن کوئری‌ها نیز انجام دهند. درباره نحوه تعامل قوانین امنیتی Cloud Firestore با جستارها بیشتر بیاموزید.

محدودیت ها

به محدودیت های زیر در پرس و جو تجمع count() توجه کنید:

  • پرس و جوهای جمع آوری count() در حال حاضر فقط از طریق پاسخ مستقیم سرور پشتیبانی می شوند. پرس و جوها فقط توسط پشتیبان Cloud Firestore ارائه می شوند و از حافظه پنهان محلی و هرگونه به روز رسانی بافر صرف نظر می شود. این رفتار مشابه عملیات انجام شده در تراکنش های Cloud Firestore است. در حال حاضر نمی توانید از پرس و جوهای count() با شنوندگان بلادرنگ و پرس و جوهای آفلاین استفاده کنید.

  • اگر تجمع count() نتواند در عرض 60 ثانیه حل شود، یک خطای DEADLINE_EXCEEDED برمی‌گرداند. عملکرد به پیکربندی شاخص شما و اندازه مجموعه داده بستگی دارد.

    اگر عملیات در مهلت 60 ثانیه تکمیل نشود، یک راه حل ممکن استفاده از شمارنده برای مجموعه داده های بزرگ است.

  • تجمع count() از ورودی های فهرست خوانده می شود و فقط فیلدهای نمایه شده را شمارش می کند.

  • افزودن یک بند OrderBy به پرس و جو، تعداد را به موجودیت هایی که خاصیت مرتب سازی وجود دارد محدود می کند.

قیمت گذاری

قیمت گذاری برای count() به تعداد ورودی های شاخص مطابق با پرس و جو بستگی دارد. برای تعداد زیادی از ورودی های منطبق، تعداد کمی از خوانده ها از شما دریافت می شود.

اطلاعات دقیق تر قیمت را مشاهده کنید.