การรวมเวลาเขียน

การค้นหาใน Cloud Firestore ช่วยให้คุณค้นหาเอกสารในคอลเล็กชันขนาดใหญ่ได้ หากต้องการรับข้อมูลเชิงลึกเกี่ยวกับพร็อพเพอร์ตี้ของคอลเล็กชันโดยรวม คุณสามารถรวบรวมข้อมูลในคอลเล็กชันได้

คุณสามารถรวบรวมข้อมูลได้เมื่ออ่านหรือเขียนข้อมูล

• การรวมข้อมูลตามเวลาในการอ่านจะคํานวณผลลัพธ์ ณ เวลาที่มีคําขอ Cloud Firestore รองรับการค้นหาการรวมข้อมูล count(), sum() และ average() ในเวลาที่อ่าน การค้นหาการรวมข้อมูลตามเวลาอ่านจะเพิ่มลงในแอปได้ง่ายกว่าการรวมข้อมูลตามเวลาเขียน ดูข้อมูลเพิ่มเติมเกี่ยวกับการค้นหาการรวมกลุ่มได้ที่สรุปข้อมูลด้วยการค้นหาการรวมกลุ่ม

• การรวมข้อมูลตามเวลาเขียนจะคํานวณผลลัพธ์ทุกครั้งที่แอปดําเนินการเขียนที่เกี่ยวข้อง การรวมข้อมูลตามเวลาที่เขียนใช้งานยากกว่า แต่คุณอาจใช้แทนการรวมข้อมูลตามเวลาที่อ่านด้วยเหตุผลข้อใดข้อหนึ่งต่อไปนี้

  • คุณต้องการฟังผลลัพธ์การรวมข้อมูลเพื่อรับข้อมูลอัปเดตแบบเรียลไทม์ การค้นหาการรวมข้อมูล count(), sum() และ average() ไม่รองรับการอัปเดตแบบเรียลไทม์
  • คุณต้องการจัดเก็บผลลัพธ์การรวมข้อมูลในแคชฝั่งไคลเอ็นต์ การค้นหาการรวมข้อมูล count(), sum() และ average() ไม่รองรับการแคช
  • คุณกำลังรวบรวมข้อมูลจากเอกสารหลายหมื่นรายการสำหรับผู้ใช้แต่ละรายและพิจารณาค่าใช้จ่าย เมื่อเอกสารมีจำนวนน้อย การรวมข้อมูลเวลาในการอ่านจะมีต้นทุนถูกลง สําหรับเอกสารจํานวนมากในการรวมข้อมูล การรวมข้อมูล ณ เวลาเขียนอาจเสียค่าใช้จ่ายน้อยกว่า

คุณสามารถใช้การรวมข้อมูลตามเวลาที่เขียนโดยใช้ธุรกรรมฝั่งไคลเอ็นต์หรือ Cloud Functions ก็ได้ ส่วนต่อไปนี้จะอธิบายวิธีใช้การรวมข้อมูลตามเวลาที่เขียน

โซลูชัน: การรวมข้อมูลตามเวลาที่เขียนด้วยธุรกรรมฝั่งไคลเอ็นต์

ลองพิจารณาแอปแนะนำในพื้นที่ซึ่งช่วยให้ผู้ใช้พบร้านอาหารดีๆ การค้นหาต่อไปนี้จะดึงข้อมูลคะแนนทั้งหมดของร้านอาหารหนึ่งๆ

เว็บ

db.collection("restaurants")
  .doc("arinell-pizza")
  .collection("ratings")
  .get();
test.solution-aggregation.js

Swift

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

do {
  let snapshot = try await db.collection("restaurants")
    .document("arinell-pizza")
    .collection("ratings")
    .getDocuments()
  print(snapshot)
} catch {
  print(error)
}
SolutionAggregationViewController.swift

Objective-C

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

FIRQuery *query = [[[self.db collectionWithPath:@"restaurants"]
    documentWithPath:@"arinell-pizza"] collectionWithPath:@"ratings"];
[query getDocumentsWithCompletion:^(FIRQuerySnapshot * _Nullable snapshot,
                                    NSError * _Nullable error) {
  // ...
}];
FIRSolutionAggregationViewController.m

Kotlin

db.collection("restaurants")
    .document("arinell-pizza")
    .collection("ratings")
    .get()
SolutionAggregation.kt

Java

db.collection("restaurants")
        .document("arinell-pizza")
        .collection("ratings")
        .get();
SolutionAggregation.java

เราจัดเก็บข้อมูลนี้ในเอกสารของร้านอาหารได้โดยไม่ต้องดึงข้อมูลการให้คะแนนทั้งหมดแล้วคำนวณข้อมูลรวม

เว็บ

var arinellDoc = {
  name: 'Arinell Pizza',
  avgRating: 4.65,
  numRatings: 683
};
test.solution-aggregation.js

Swift

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

struct Restaurant {

  let name: String
  let avgRating: Float
  let numRatings: Int

}

let arinell = Restaurant(name: "Arinell Pizza", avgRating: 4.65, numRatings: 683)
SolutionAggregationViewController.swift

Objective-C

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

@interface FIRRestaurant : NSObject

@property (nonatomic, readonly) NSString *name;
@property (nonatomic, readonly) float averageRating;
@property (nonatomic, readonly) NSInteger ratingCount;

- (instancetype)initWithName:(NSString *)name
               averageRating:(float)averageRating
                 ratingCount:(NSInteger)ratingCount;

@end

@implementation FIRRestaurant

- (instancetype)initWithName:(NSString *)name
               averageRating:(float)averageRating
                 ratingCount:(NSInteger)ratingCount {
  self = [super init];
  if (self != nil) {
    _name = name;
    _averageRating = averageRating;
    _ratingCount = ratingCount;
  }
  return self;
}

@end
FIRSolutionAggregationViewController.m

Kotlin

data class Restaurant(
    // default values required for use with "toObject"
    internal var name: String = "",
    internal var avgRating: Double = 0.0,
    internal var numRatings: Int = 0,
)

val arinell = Restaurant("Arinell Pizza", 4.65, 683)
SolutionAggregation.kt

Java

public class Restaurant {
    String name;
    double avgRating;
    int numRatings;

    public Restaurant(String name, double avgRating, int numRatings) {
        this.name = name;
        this.avgRating = avgRating;
        this.numRatings = numRatings;
    }
}

Restaurant arinell = new Restaurant("Arinell Pizza", 4.65, 683);
SolutionAggregation.java

ข้อมูลสรุปเหล่านี้ต้องได้รับการอัปเดตทุกครั้งที่มีการเพิ่มการจัดประเภทใหม่ลงในคอลเล็กชันย่อยเพื่อให้มีความสอดคล้องกัน วิธีหนึ่งในการทำให้ข้อมูลสอดคล้องกันคือการเพิ่มและการอัปเดตในธุรกรรมเดียว ดังนี้

เว็บ

function addRating(restaurantRef, rating) {
    // Create a reference for a new rating, for use inside the transaction
    var ratingRef = restaurantRef.collection('ratings').doc();

    // In a transaction, add the new rating and update the aggregate totals
    return db.runTransaction((transaction) => {
        return transaction.get(restaurantRef).then((res) => {
            if (!res.exists) {
                throw "Document does not exist!";
            }

            // Compute new number of ratings
            var newNumRatings = res.data().numRatings + 1;

            // Compute new average rating
            var oldRatingTotal = res.data().avgRating * res.data().numRatings;
            var newAvgRating = (oldRatingTotal + rating) / newNumRatings;

            // Commit to Firestore
            transaction.update(restaurantRef, {
                numRatings: newNumRatings,
                avgRating: newAvgRating
            });
            transaction.set(ratingRef, { rating: rating });
        });
    });
}
test.firestore.js

Swift

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

func addRatingTransaction(restaurantRef: DocumentReference, rating: Float) async {
  let ratingRef: DocumentReference = restaurantRef.collection("ratings").document()

  do {
    let _ = try await db.runTransaction({ (transaction, errorPointer) -> Any? in
      do {
        let restaurantDocument = try transaction.getDocument(restaurantRef).data()
        guard var restaurantData = restaurantDocument else { return nil }

        // Compute new number of ratings
        let numRatings = restaurantData["numRatings"] as! Int
        let newNumRatings = numRatings + 1

        // Compute new average rating
        let avgRating = restaurantData["avgRating"] as! Float
        let oldRatingTotal = avgRating * Float(numRatings)
        let newAvgRating = (oldRatingTotal + rating) / Float(newNumRatings)

        // Set new restaurant info
        restaurantData["numRatings"] = newNumRatings
        restaurantData["avgRating"] = newAvgRating

        // Commit to Firestore
        transaction.setData(restaurantData, forDocument: restaurantRef)
        transaction.setData(["rating": rating], forDocument: ratingRef)
      } catch {
        // Error getting restaurant data
        // ...
      }

      return nil
    })
  } catch {
    // ...
  }
}
SolutionAggregationViewController.swift

Objective-C

หมายเหตุ: ผลิตภัณฑ์นี้ไม่พร้อมใช้งานบนเป้าหมาย watchOS และ App Clip

- (void)addRatingTransactionWithRestaurantReference:(FIRDocumentReference *)restaurant
                                             rating:(float)rating {
  FIRDocumentReference *ratingReference =
      [[restaurant collectionWithPath:@"ratings"] documentWithAutoID];

  [self.db runTransactionWithBlock:^id (FIRTransaction *transaction,
                                        NSError **errorPointer) {
    FIRDocumentSnapshot *restaurantSnapshot =
        [transaction getDocument:restaurant error:errorPointer];

    if (restaurantSnapshot == nil) {
      return nil;
    }

    NSMutableDictionary *restaurantData = [restaurantSnapshot.data mutableCopy];
    if (restaurantData == nil) {
      return nil;
    }

    // Compute new number of ratings
    NSInteger ratingCount = [restaurantData[@"numRatings"] integerValue];
    NSInteger newRatingCount = ratingCount + 1;

    // Compute new average rating
    float averageRating = [restaurantData[@"avgRating"] floatValue];
    float newAverageRating = (averageRating * ratingCount + rating) / newRatingCount;

    // Set new restaurant info

    restaurantData[@"numRatings"] = @(newRatingCount);
    restaurantData[@"avgRating"] = @(newAverageRating);

    // Commit to Firestore
    [transaction setData:restaurantData forDocument:restaurant];
    [transaction setData:@{@"rating": @(rating)} forDocument:ratingReference];
    return nil;
  } completion:^(id  _Nullable result, NSError * _Nullable error) {
    // ...
  }];
}
FIRSolutionAggregationViewController.m

Kotlin

private fun addRating(restaurantRef: DocumentReference, rating: Float): Task<Void> {
    // Create reference for new rating, for use inside the transaction
    val ratingRef = restaurantRef.collection("ratings").document()

    // In a transaction, add the new rating and update the aggregate totals
    return db.runTransaction { transaction ->
        val restaurant = transaction.get(restaurantRef).toObject<Restaurant>()!!

        // Compute new number of ratings
        val newNumRatings = restaurant.numRatings + 1

        // Compute new average rating
        val oldRatingTotal = restaurant.avgRating * restaurant.numRatings
        val newAvgRating = (oldRatingTotal + rating) / newNumRatings

        // Set new restaurant info
        restaurant.numRatings = newNumRatings
        restaurant.avgRating = newAvgRating

        // Update restaurant
        transaction.set(restaurantRef, restaurant)

        // Update rating
        val data = hashMapOf<String, Any>(
            "rating" to rating,
        )
        transaction.set(ratingRef, data, SetOptions.merge())

        null
    }
}
SolutionAggregation.kt

Java

private Task<Void> addRating(final DocumentReference restaurantRef, final float rating) {
    // Create reference for new rating, for use inside the transaction
    final DocumentReference ratingRef = restaurantRef.collection("ratings").document();

    // In a transaction, add the new rating and update the aggregate totals
    return db.runTransaction(new Transaction.Function<Void>() {
        @Override
        public Void apply(@NonNull Transaction transaction) throws FirebaseFirestoreException {
            Restaurant restaurant = transaction.get(restaurantRef).toObject(Restaurant.class);

            // Compute new number of ratings
            int newNumRatings = restaurant.numRatings + 1;

            // Compute new average rating
            double oldRatingTotal = restaurant.avgRating * restaurant.numRatings;
            double newAvgRating = (oldRatingTotal + rating) / newNumRatings;

            // Set new restaurant info
            restaurant.numRatings = newNumRatings;
            restaurant.avgRating = newAvgRating;

            // Update restaurant
            transaction.set(restaurantRef, restaurant);

            // Update rating
            Map<String, Object> data = new HashMap<>();
            data.put("rating", rating);
            transaction.set(ratingRef, data, SetOptions.merge());

            return null;
        }
    });
}
SolutionAggregation.java

การใช้ธุรกรรมช่วยให้ข้อมูลรวมสอดคล้องกับคอลเล็กชันพื้นฐาน หากต้องการอ่านเพิ่มเติมเกี่ยวกับธุรกรรมใน Cloud Firestore ให้ดูธุรกรรมและการเขียนแบบเป็นกลุ่ม

ข้อจำกัด

โซลูชันที่แสดงด้านบนแสดงการรวบรวมข้อมูลโดยใช้Cloud Firestoreไลบรารีไคลเอ็นต์ แต่คุณควรทราบข้อจํากัดต่อไปนี้

• ความปลอดภัย - ธุรกรรมฝั่งไคลเอ็นต์ต้องให้สิทธิ์ไคลเอ็นต์เพื่ออัปเดตข้อมูลรวมในฐานข้อมูล แม้ว่าคุณจะลดความเสี่ยงของแนวทางนี้ได้ด้วยการเขียนกฎความปลอดภัยขั้นสูง แต่วิธีนี้อาจไม่เหมาะสมในบางสถานการณ์
• การรองรับแบบออฟไลน์ - ธุรกรรมฝั่งไคลเอ็นต์จะดำเนินการไม่สำเร็จเมื่ออุปกรณ์ของผู้ใช้ออฟไลน์ ซึ่งหมายความว่าคุณต้องจัดการเคสนี้ในแอปและลองอีกครั้งในเวลาที่เหมาะสม
• ประสิทธิภาพ - หากธุรกรรมของคุณมีการดำเนินการอ่าน เขียน และอัปเดตหลายรายการ ระบบอาจต้องส่งคำขอไปยังแบ็กเอนด์ Cloud Firestore หลายรายการ การดำเนินการนี้อาจใช้เวลานานมากบนอุปกรณ์เคลื่อนที่
• อัตราการเขียน - โซลูชันนี้อาจใช้ไม่ได้กับการรวมข้อมูลที่มีการอัปเดตบ่อย เนื่องจากเอกสาร Cloud Firestore อัปเดตได้สูงสุด 1 ครั้งต่อวินาที นอกจากนี้ หากธุรกรรมอ่านเอกสารที่มีการแก้ไขนอกธุรกรรม ธุรกรรมจะพยายามอ่านอีกครั้งตามจำนวนครั้งที่จำกัดแล้วดำเนินการไม่สำเร็จ ดูตัวนับแบบกระจายเพื่อหาวิธีแก้ปัญหาที่เกี่ยวข้องสําหรับการรวมข้อมูลที่ต้องอัปเดตบ่อยขึ้น

โซลูชัน: การรวมข้อมูล ณ เวลาเขียนด้วย Cloud Functions

หากธุรกรรมฝั่งไคลเอ็นต์ไม่เหมาะกับแอปพลิเคชันของคุณ คุณสามารถใช้ฟังก์ชัน Cloud เพื่ออัปเดตข้อมูลรวมทุกครั้งที่มีการเพิ่มการให้คะแนนใหม่ให้กับร้านอาหาร ดังนี้

Node.js

exports.aggregateRatings = functions.firestore
    .document('restaurants/{restId}/ratings/{ratingId}')
    .onWrite(async (change, context) => {
      // Get value of the newly added rating
      const ratingVal = change.after.data().rating;

      // Get a reference to the restaurant
      const restRef = db.collection('restaurants').doc(context.params.restId);

      // Update aggregations in a transaction
      await db.runTransaction(async (transaction) => {
        const restDoc = await transaction.get(restRef);

        // Compute new number of ratings
        const newNumRatings = restDoc.data().numRatings + 1;

        // Compute new average rating
        const oldRatingTotal = restDoc.data().avgRating * restDoc.data().numRatings;
        const newAvgRating = (oldRatingTotal + ratingVal) / newNumRatings;

        // Update restaurant info
        transaction.update(restRef, {
          avgRating: newAvgRating,
          numRatings: newNumRatings
        });
      });
    });
index.js

โซลูชันนี้จะกระจายงานจากไคลเอ็นต์ไปยังฟังก์ชันที่โฮสต์ ซึ่งหมายความว่าแอปบนอุปกรณ์เคลื่อนที่จะเพิ่มการให้คะแนนได้โดยไม่ต้องรอให้ธุรกรรมเสร็จสมบูรณ์ โค้ดที่ดำเนินการใน Cloud Function จะไม่ผูกพันกับกฎด้านความปลอดภัย ซึ่งหมายความว่าคุณไม่จําเป็นต้องให้สิทธิ์การเขียนข้อมูลรวมแก่ลูกค้าอีกต่อไป

ข้อจำกัด

การใช้ Cloud Function สำหรับการรวมข้อมูลจะช่วยหลีกเลี่ยงปัญหาบางอย่างเกี่ยวกับธุรกรรมฝั่งไคลเอ็นต์ แต่มีข้อจํากัดอีกชุดหนึ่งดังนี้

• ค่าใช้จ่าย - การให้คะแนนแต่ละรายการที่เพิ่มจะทำให้เกิดการเรียกใช้ Cloud Function ซึ่งอาจทำให้ค่าใช้จ่ายเพิ่มขึ้น ดูข้อมูลเพิ่มเติมได้ที่หน้าราคาของ Cloud Functions
• เวลาในการตอบสนอง - เมื่อมีการย้ายงานการรวมข้อมูลไปยัง Cloud Functions แอปของคุณจะไม่เห็นข้อมูลที่อัปเดตจนกว่า Cloud Functions จะดำเนินการเสร็จสิ้นและลูกค้าได้รับการแจ้งเตือนเกี่ยวกับข้อมูลใหม่ การดำเนินการนี้อาจใช้เวลานานกว่าการดำเนินการธุรกรรมในเครื่อง ทั้งนี้ขึ้นอยู่กับความเร็วของ Cloud Function
• อัตราการเขียน - โซลูชันนี้อาจใช้ไม่ได้กับการรวมข้อมูลที่มีการอัปเดตบ่อย เนื่องจากเอกสาร Cloud Firestore อัปเดตได้สูงสุด 1 ครั้งต่อวินาที นอกจากนี้ หากธุรกรรมอ่านเอกสารที่มีการแก้ไขนอกธุรกรรม ธุรกรรมจะลองใหม่ตามจำนวนครั้งที่จำกัดแล้วดำเนินการไม่สำเร็จ ดูตัวนับแบบกระจายเพื่อหาวิธีแก้ปัญหาที่เกี่ยวข้องสําหรับการรวมข้อมูลที่ต้องอัปเดตบ่อยขึ้น