Работа с восстановлением на момент времени (PITR)

Консоль

1. В консоли Google Cloud перейдите на страницу «Базы данных» .

   Перейти к базам данных

2. Выберите нужную базу данных из списка баз данных.

3. В меню навигации нажмите Аварийное восстановление .

4. Нажмите «Изменить», чтобы изменить настройки.

5. Установите флажок «Включить восстановление на определенный момент времени» и нажмите «Сохранить» .

Включение PITR повлечет за собой затраты на хранение. См. «Цены» для получения дополнительной информации.

Чтобы отключить PITR, снимите флажок «Включить восстановление на определенный момент времени» на странице «Аварийное восстановление» в консоли Google Cloud.

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 перейдите на страницу «Базы данных» .

   Перейти к базам данных

2. Выберите нужную базу данных из списка баз данных.

3. В меню навигации нажмите Аварийное восстановление .

4. В разделе «Настройки » обратите внимание на « Период хранения» и «Время самой ранней версии» .

   • Период хранения : период, в течение которого Cloud Firestore сохраняет все версии данных для базы данных. Значение равно одному часу, когда PITR отключен, и семи дням, когда PITR включен.
   • Время самой ранней версии : самая ранняя временная метка, с которой более старые версии данных можно прочитать в окне PITR. Это значение постоянно обновляется Cloud Firestore и становится устаревшим в момент запроса. Если вы используете это значение для восстановления данных, обязательно учтите время с момента запроса значения до момента начала восстановления.
   • Восстановление на определенный момент времени : отображается Enabled , если PITR включен. Если PITR отключен, вы увидите Disabled .

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/DATABASE_ID
    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)}
  )

ОТДЫХ API

Чтения PITR поддерживаются во всех методах чтения Cloud Firestore , а именно get , list , atchGet , listCollectionIds , listDocuments , runQuery , runAggregationQuery иsectionQuery .

Чтобы выполнить чтение с использованием методов REST, попробуйте один из следующих вариантов:

1. В запросе метода чтения передайте значение readTime как поддерживаемую временную метку PITR в методе readOptions . Временная метка PITR может быть либо временной меткой с точностью до микросекунды в течение последнего часа, либо временной меткой целой минуты за прошедший час, но не раньше, чем earliestVersionTime .

2. Используйте параметр readTime вместе с методом BeginTransaction как часть транзакции ReadOnly для нескольких операций чтения PITR.

Апачский луч

Используйте коннектор Cloud Firestore IO Apache Beam для чтения или записи документов в базе данных Cloud Firestore в больших масштабах с помощью Dataflow.

Чтения PITR поддерживаются следующим методом чтения соединителя ввода-вывода Cloud Firestore . Эти методы чтения поддерживают метод 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 .