العمل مع الاسترداد في الوقت المحدد (PITR)

وحدة التحكم

1. في Google Cloud Platform Console، انتقل إلى صفحة قواعد البيانات .

   اذهب إلى قواعد البيانات

2. قم باختيار قاعدة البيانات المطلوبة من قائمة قواعد البيانات.

3. في قائمة التنقل، انقر فوق التعافي من الكوارث .

4. انقر فوق "تحرير" لتحرير الإعدادات.

5. حدد خانة الاختيار تمكين الاسترداد في الوقت المناسب ، ثم انقر فوق حفظ .

قد يؤدي تمكين PITR إلى تحمل تكاليف التخزين. انظر التسعير لمزيد من المعلومات.

لتعطيل PITR، قم بإلغاء تحديد خانة الاختيار تمكين الاسترداد في الوقت المناسب من صفحة التعافي من الكوارث في وحدة تحكم GCP.

com.gcloud

قم بتمكين PITR أثناء إنشاء قاعدة البيانات باستخدام أمر gcloud firestore databases create كما يلي:

gcloud firestore databases create\
  --location=LOCATION\
  [--database=DATABASE_ID; default="(default)"]\
  [--type=TYPE; default="firestore-native"]\
  --enable-pitr

استبدل القيم كما يلي:

• Location - الموقع الذي تريد إنشاء قاعدة بياناتك فيه.
• DATABASE_ID - تم تعيينه على معرف قاعدة البيانات أو (افتراضي).
• TYPE - تم ضبطه على firestore-native.

يمكنك تعطيل PITR باستخدام أمر gcloud firestore databases update كما يلي:

gcloud firestore databases update\
  [--database=DATABASE_ID; default="(default)"]\
  --no-enable-pitr

استبدل القيم كما يلي:

• DATABASE_ID - تم تعيينه على معرف قاعدة البيانات أو (افتراضي).

وحدة التحكم

1. في Google Cloud Platform Console، انتقل إلى صفحة قواعد البيانات .

   اذهب إلى قواعد البيانات

2. قم باختيار قاعدة البيانات المطلوبة من قائمة قواعد البيانات.

3. في قائمة التنقل، انقر فوق التعافي من الكوارث .

4. في قسم الإعدادات ، لاحظ فترة الاحتفاظ وأقدم وقت للإصدار .

   • فترة الاستبقاء : الفترة التي يحتفظ فيها Cloud Firestore بجميع إصدارات البيانات الخاصة بقاعدة البيانات. القيمة هي ساعة واحدة عند تعطيل PITR وسبعة أيام عند تمكين PITR.
   • وقت الإصدار الأقدم : الطابع الزمني الأقدم الذي يمكن من خلاله قراءة الإصدارات الأقدم من البيانات في نافذة PITR. يتم تحديث هذه القيمة بشكل مستمر بواسطة Cloud Firestore وتصبح قديمة لحظة الاستعلام عنها. إذا كنت تستخدم هذه القيمة لاسترداد البيانات، فتأكد من مراعاة الوقت من لحظة الاستعلام عن القيمة إلى لحظة بدء الاسترداد.
   • استرداد النقطة الزمنية : يظهر Enabled ، إذا تم تمكين PITR. إذا تم تعطيل PITR، فسترى Disabled .

com.gcloud

قم بتشغيل قواعد بيانات gcloud firestore التي تصف الأمر كما يلي:

gcloud firestore databases describe --database=DATABASE_ID

استبدل DATABASE_ID بمعرف قاعدة البيانات أو default .

وهنا الإخراج:

    appEngineIntegrationMode: ENABLED
    concurrencyMode: PESSIMISTIC
    createTime: '2021-03-24T17:02:35.234Z'
    deleteProtectionState: DELETE_PROTECTION_DISABLED
    earliestVersionTime: '2023-06-12T16:17:25.222474Z'
    etag: IIDayqOevv8CMNTvyNK4uv8C
    keyPrefix: s
    locationId: nam5
    name: projects/PROJECT_ID/databases/(default)
    pointInTimeRecoveryEnablement: POINT_IN_TIME_RECOVERY_DISABLED
    type: FIRESTORE_NATIVE
    uid: 5230c382-dcd2-468f-8cb3-2a1acfde2b32
    updateTime: '2021-11-17T17:48:22.171180Z'
    versionRetentionPeriod: 3600s

أين،

• earliestVersionTime - الطابع الزمني لأقدم بيانات PITR المخزنة.
• pointInTimeRecoveryEnablement : يعرض POINT_IN_TIME_RECOVERY_ENABLED ، إذا تم تمكين PITR. إذا تم تعطيل PITR، فسوف ترى إما POINT_IN_TIME_RECOVERY_DISABLED أو قد لا يتم عرض حقل pointInTimeRecoveryEnablement .
• versionRetentionPeriod - الفترة الزمنية التي يتم خلالها الاحتفاظ ببيانات PITR بالمللي ثانية. يمكن أن تكون القيمة ساعة واحدة عند تعطيل PITR أو سبعة أيام إذا تم تمكين PITR.

مكتبات العملاء

  Firestore firestore = …

  TransactionOptions options =
          TransactionOptions.createReadOnlyOptionsBuilder()
              .setReadTime(
                  com.google.protobuf.Timestamp.newBuilder()
                      .setSeconds(1684098540L)
                      .setNanos(0))
              .build();

  ApiFuture<Void> futureTransaction = firestore.runTransaction(
              transaction -> {
                // Does a snapshot read document lookup
                final DocumentSnapshot documentResult =
                    transaction.get(documentReference).get();

                // Executes a snapshot read query
                final QuerySnapshot queryResult =
                  transaction.get(query).get();
              },
              options);

  // Blocks on transaction to complete
  futureTransaction.get();

  const documentSnapshot = await firestore.runTransaction(
    updateFunction => updateFunction.get(documentRef),
    {readOnly: true, readTime: new Firestore.Timestamp(1684098540, 0)}
);

  const querySnapshot = await firestore.runTransaction(
    updateFunction => updateFunction.get(query),
    {readOnly: true, readTime: new Firestore.Timestamp(1684098540, 0)}
  )

واجهة برمجة تطبيقات REST

يتم دعم قراءات PITR في جميع أساليب القراءة في Cloud Firestore، وهي get و list و bachGet و listCollectionIds و listDocuments و runQuery و runAggregationQuery و partitionQuery .

لإجراء قراءة باستخدام أساليب REST، جرب أحد الخيارات التالية:

1. في طلب أسلوب القراءة الخاص بك، قم بتمرير قيمة readTime كطابع زمني PITR مدعوم في أسلوب readOptions . يمكن أن يكون الطابع الزمني PITR إما طابعًا زمنيًا بدقة ميكروثانية خلال الساعة الماضية أو طابعًا زمنيًا لدقيقة كاملة بعد الساعة الماضية، ولكن ليس قبل أقدم إصدار من earliestVersionTime .

2. استخدم معلمة readTime مع أسلوب BeginTransaction كجزء من معاملة ReadOnly لقراءات PITR المتعددة.

أباتشي شعاع

استخدم موصل Cloud FirestoreIO Apache Beam لقراءة المستندات أو كتابتها في قاعدة بيانات Cloud Firestore على نطاق واسع باستخدام Dataflow.

يتم دعم قراءات PITR في طريقة القراءة التالية لموصل Cloud FirestoreIO. تدعم طرق القراءة هذه طريقة withReadTime(@Nullable Instant readTime) التي يمكنك استخدامها لقراءات PITR:

• FirestoreV1.BatchGetDocuments
• FirestoreV1.ListCollectionIds
• FirestoreV1.ListDocuments
• FirestoreV1.PartitionQuery

• FirestoreV1.RunQuery

  Instant readTime = Instant.ofEpochSecond(1684098540L);

  PCollection<Document> documents =
      pipeline
          .apply(Create.of(collectionId))
          .apply(
              new FilterDocumentsQuery(
                  firestoreOptions.getProjectId(), firestoreOptions.getDatabaseId()))
          .apply(FirestoreIO.v1().read().runQuery().withReadTime(readTime).withRpcQosOptions(rpcQosOptions).build())
  ...

للحصول على قائمة كاملة بأمثلة readTime في مسار Dataflow، راجع مستودع Github .