Чтобы переводить контент на ваш предпочитаемый язык, Google использует технологии на основе искусственного интеллекта. Переводы от ИИ могут содержать ошибки.

Как изменить стратегию сжатия Cassandra

Apigee использует базу данных Cassandra для хранения большей части своих данных, включая данные для прокси-серверов, кешей и токенов. Сжатие – это важный процесс, который позволяет уменьшить размер данных, хранящихся в базах данных, и обеспечить эффективную работу баз данных. Cassandra поддерживает различные стратегии сжатия. Apigee рекомендует всем клиентам Edge for Private Cloud использовать для кластеров Cassandra коэффициент репликации LeveledCompactionStrategy, а не SizeTieredCompactionStrategy, для всех таблиц. LeveledCompactionStrategy обеспечивает более высокую производительность, более эффективное использование диска и сжатие, а также требует меньше свободного места, чем SizeTieredCompactionStrategy.

Во всех новых установках Edge для частного облака версии 4.52.02 или более поздней Cassandra автоматически настраивается с помощью LeveledCompactionStrategy. Однако если вы обновили Edge для частного облака до версии 4.54.00 с более ранней версии, в вашей установке может по-прежнему использоваться Cassandra с SizeTieredCompactionStrategy.

Хотя мы не рекомендуем менять стратегию сжатия на что-либо, кроме LeveledCompactionStrategy, в этом документе описано, как внести изменения, если это необходимо, и приведены инструкции по проверке текущей стратегии сжатия. Если вы выберете нерекомендуемую стратегию сжатия, то при последующих обновлениях ПО Cassandra ваши изменения могут быть перезаписаны. Если вы используете нестандартный подход, рекомендуем проверять стратегию сжатия после каждого обновления.

Подготовка

Требования

В Edge для Private Cloud 4.54.00 для Cassandra 5.x требуется JDK 17 (Java 17). Прежде чем выполнять команды nodetool или cqlsh на узле Cassandra, убедитесь, что Java 17 настроена как версия Java по умолчанию (например, выполнив команду sudo alternatives --set java JAVA_17_PATH/bin/java или указав в переменной JAVA_HOME путь к JDK 17).

Проверьте существующую стратегию сжатия

Проверить текущую стратегию сжатия таблиц можно по инструкциям в приложении 1. Если стратегия сжатия уже имеет значение LeveledCompactionStrategy, это может быть связано с тем, что вы начали с установки Edge для Private Cloud 4.51 или более поздней версии или ранее перешли на LeveledCompactionStrategy, как рекомендовано Apigee. Если вы уже используете LeveledCompactionStrategy, Apigee рекомендует продолжать использовать эту стратегию и избегать изменений. Однако, поскольку вы управляете Edge для частного облака, в следующих инструкциях объясняется, как при желании изменить стратегию сжатия.

Внимание! Если вы обратитесь в службу поддержки Apigee по поводу проблемы, которая могла быть вызвана Cassandra, вас, скорее всего, попросят сначала изменить кластер, чтобы использовать рекомендуемую стратегию сжатия (LeveledCompactionStrategy), прежде чем устранять неполадки.

Резервное копирование

Поскольку изменение стратегии сжатия запускает полный цикл сжатия в узлах Cassandra, это может привести к задержкам из-за нагрузки, связанной со сжатием и одновременным трафиком приложений. Чтобы отменить это изменение, не нужно восстанавливать данные из резервной копии. Вы можете отменить стратегию сжатия напрямую, как описано в разделе Вариант 1. Отмена изменения. Однако в качестве меры предосторожности рекомендуем создать резервную копию данных перед изменением стратегии сжатия.

Пропускная способность уплотнения

После того как стратегия сжатия будет изменена на LeveledCompactionStrategy, сжатие может выполняться долго. Время выполнения зависит от размера сжатых данных. Во время сжатия Cassandra может использовать больше системных ресурсов. Чтобы сжатие не занимало много системных ресурсов и не мешало запросам API Runtime, рекомендуем установить ограничения на пропускную способность сжатия.

Выполните следующую команду nodetool на каждом из узлов, чтобы установить максимальную пропускную способность уплотнения на уровне 128 МБ на всех узлах Cassandra:

nodetool setcompactionthroughput 128

Как выбрать размер ВМ для сжатия

Перед выполнением этого изменения убедитесь, что узлы Cassandra имеют достаточно ресурсов ЦП и памяти и работают при загрузке ЦП не более 25%.

После изменения стратегии сжатия ожидается запуск полного цикла сжатия, поэтому рекомендуется изменить стратегию сжатия в периоды низкого трафика.

Запуски в шахматном порядке

Возможно, вы не сможете изменить все узлы за один день, особенно если вы работаете с большими кластерами Cassandra, поскольку индексы необходимо перестраивать на каждом узле по одному. Вы можете изменить стратегию сжатия одной схемы или одной таблицы за раз. Для этого измените таблицу, чтобы изменить стратегию сжатия, а затем перестройте все индексы в таблице (если они есть) на всех узлах. Затем повторите описанные выше действия для каждой таблицы или каждого пространства ключей. Такие операции для одной таблицы или одного пространства ключей можно разбить на несколько дней.

Например, чтобы изменить стратегию сжатия таблицы oauth_20_access_tokens в схеме kms на LeveledCompactionStrategy, выполните следующие действия:

Измените таблицу, чтобы изменить стратегию сжатия, выполнив следующий CQL:
```
ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
```

Перестроить все индексы только этой таблицы:

nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_app_id_idx
nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_client_id_idx
nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_refresh_token_idx

Как изменить стратегию сжатия

В целом изменение стратегии сжатия состоит из двух этапов:

Измените стратегию сжатия для каждой таблицы.
Перестройте все индексы на каждом узле по очереди.

Чтобы изменить стратегию сжатия, необходимо выполнить команду ALTER TABLE для каждой таблицы по очереди. Пример команды ALTER TABLE:

# To change to LeveledCompactionStrategy
ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  
# To change to SizeTieredCompactionStrategy
ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'SizeTieredCompactionStrategy'};

Изменить таблицу, чтобы задать новую стратегию сжатия

Выполните следующие CQL на любом узле Cassandra, чтобы изменить стратегию для одного пространства ключей за раз. Запросы CQL можно выполнять в командной строке CQL. Инструкции по вызову запроса CQL:

/opt/apigee/apigee-cassandra/bin/cqlsh `hostname -i`

Подключено к Apigee по адресу XXXXXXXX:9042.

[cqlsh 6.2.0 | Cassandra 5.0.8 | CQL spec 3.4.7 | Native protocol v5]
Use HELP for help.
cqlsh>

В приведенных ниже командах стратегия сжатия меняется на LeveledCompactionStrategy, но аналогичные команды можно использовать для изменения на другие стратегии сжатия.

Шаги 14–16 ниже применимы только в том случае, если вы используете монетизацию.

CQL для изменения стратегии сжатия для пространства ключей: kms

ALTER TABLE kms.organizations WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.maps WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.apps WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.app_credentials WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.api_products WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.apiproducts_appslist WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.api_resources WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.app_end_user WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.oauth_20_authorization_codes WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.oauth_10_request_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.oauth_10_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.oauth_10_verifiers WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE kms.app_enduser_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL-запросы для изменения стратегии сжатия для пространства ключей: user_settings
```
ALTER TABLE user_settings.user_settings WITH compaction = {'class' : 'LeveledCompactionStrategy'};
```
CQL-запросы для изменения стратегии сжатия для пространства ключей: keyvaluemap
```
ALTER TABLE keyvaluemap.keyvaluemaps_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
```

CQL для изменения стратегии сжатия для пространства ключей: devconnect

ALTER TABLE devconnect.developers WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE devconnect.companies WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE devconnect.company_developers WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: counter

ALTER TABLE counter.counters_current_version WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.counters_with_expiry WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.counters WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.key_timestamp_count WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.timestamp_key WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.period_timestamp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE counter.gateway_quota WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: cache

ALTER TABLE cache.cache_entries WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE cache.cache_sequence_id_r24 WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: auth
```
ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
```

CQL для изменения стратегии сжатия для пространства ключей: audit

ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: apprepo

ALTER TABLE apprepo.organizations WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apprepo.environments WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apprepo.apiproxies WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apprepo.apiproxy_revisions WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apprepo.api_proxy_revisions_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: apimodel_v2

ALTER TABLE apimodel_v2.apis WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.apis_revision WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.resource WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.method WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.revision_counters WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.template_counters WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.template WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.credentials WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.credentialsv2 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.schemas WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.security WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE apimodel_v2.template_auth WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL-запросы для изменения стратегии сжатия для пространства ключей: identityzone

ALTER TABLE identityzone.IdentityZones WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE identityzone.OrgToIdentityZone WITH compaction = {'class' : 'LeveledCompactionStrategy'};

CQL для изменения стратегии сжатия для пространства ключей: dek
```
ALTER TABLE dek.keys WITH compaction = {'class' : 'LeveledCompactionStrategy'};
```

CQL-запросы для изменения стратегии сжатия для пространства ключей: analytics

ALTER TABLE analytics.custom_aggregates_defn WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE analytics.custom_rules_defn WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE analytics.custom_aggregates_defn_updates WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE analytics.custom_rules_defn_updates WITH compaction = {'class' : 'LeveledCompactionStrategy'};

[Только монетизация] CQL-запросы для изменения стратегии сжатия пространства ключей: mint

ALTER TABLE mint.limits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE mint.suspended_developer_products WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE mint.invitations WITH compaction = {'class' : 'LeveledCompactionStrategy'};

[Только монетизация] CQL-запросы для изменения стратегии сжатия для пространства ключей: taurus

ALTER TABLE taurus.triggers WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE taurus.job_details WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE taurus.org_triggers WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE taurus.triggers_suite WITH compaction = {'class' : 'LeveledCompactionStrategy'};

[Только монетизация] CQL-запросы для изменения стратегии сжатия пространства ключей: notification

ALTER TABLE notification.notification_service_item WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE notification.notification_service_black_list_item WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE notification.notification_email_template_item WITH compaction = {'class' : 'LeveledCompactionStrategy'};

Как перестроить индексы

Этот шаг необходимо выполнить после любого изменения стратегии сжатия. Выполните следующие команды nodetool по очереди на каждом узле Cassandra.

Шаги 7–9 ниже относятся только к тем, кто использует монетизацию.

Перестроить индексы для пространства ключей: kms

nodetool rebuild_index kms api_products api_products_organization_name_idx
nodetool rebuild_index kms app_credentials app_credentials_api_products_idx
nodetool rebuild_index kms app_credentials app_credentials_organization_app_id_idx
nodetool rebuild_index kms app_credentials app_credentials_organization_name_idx
nodetool rebuild_index kms app_end_user app_end_user_app_id_idx
nodetool rebuild_index kms apps apps_app_family_idx
nodetool rebuild_index kms apps apps_app_id_idx
nodetool rebuild_index kms apps apps_app_type_idx
nodetool rebuild_index kms apps apps_name_idx
nodetool rebuild_index kms apps apps_organization_name_idx
nodetool rebuild_index kms apps apps_parent_id_idx
nodetool rebuild_index kms apps apps_parent_status_idx
nodetool rebuild_index kms apps apps_status_idx
nodetool rebuild_index kms maps maps_organization_name_idx
nodetool rebuild_index kms oauth_10_access_tokens oauth_10_access_tokens_app_id_idx
nodetool rebuild_index kms oauth_10_access_tokens oauth_10_access_tokens_consumer_key_idx
nodetool rebuild_index kms oauth_10_access_tokens oauth_10_access_tokens_organization_name_idx
nodetool rebuild_index kms oauth_10_access_tokens oauth_10_access_tokens_status_idx
nodetool rebuild_index kms oauth_10_request_tokens oauth_10_request_tokens_consumer_key_idx
nodetool rebuild_index kms oauth_10_request_tokens oauth_10_request_tokens_organization_name_idx
nodetool rebuild_index kms oauth_10_verifiers oauth_10_verifiers_organization_name_idx
nodetool rebuild_index kms oauth_10_verifiers oauth_10_verifiers_request_token_idx
nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_app_id_idx
nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_client_id_idx
nodetool rebuild_index kms oauth_20_access_tokens oauth_20_access_tokens_refresh_token_idx
nodetool rebuild_index kms oauth_20_authorization_codes oauth_20_authorization_codes_client_id_idx
nodetool rebuild_index kms oauth_20_authorization_codes oauth_20_authorization_codes_organization_name_idx

Перестроение индексов для пространства ключей: devconnect

nodetool rebuild_index devconnect companies companies_name_idx
nodetool rebuild_index devconnect companies companies_organization_name_idx
nodetool rebuild_index devconnect companies companies_status_idx
nodetool rebuild_index devconnect company_developers company_developers_company_name_idx
nodetool rebuild_index devconnect company_developers company_developers_developer_email_idx
nodetool rebuild_index devconnect company_developers company_developers_organization_name_idx
nodetool rebuild_index devconnect developers developers_email_idx
nodetool rebuild_index devconnect developers developers_organization_name_idx
nodetool rebuild_index devconnect developers developers_status_idx

Перестроение индексов для пространства ключей: cache
```
nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx
```

Перестроить индексы для пространства ключей: audit

nodetool rebuild_index audit audits audits_operation_idx
nodetool rebuild_index audit audits audits_requesturi_idx
nodetool rebuild_index audit audits audits_responsecode_idx
nodetool rebuild_index audit audits audits_timestamp_idx
nodetool rebuild_index audit audits audits_user_idx

Перестроить индексы для пространства ключей: apimodel_v2

nodetool rebuild_index apimodel_v2 apis a_name
nodetool rebuild_index apimodel_v2 apis a_org_name
nodetool rebuild_index apimodel_v2 apis_revision ar_a_active_rev
nodetool rebuild_index apimodel_v2 apis_revision ar_a_def_index_template
nodetool rebuild_index apimodel_v2 apis_revision ar_a_def_method_template
nodetool rebuild_index apimodel_v2 apis_revision ar_a_latest_rev
nodetool rebuild_index apimodel_v2 apis_revision ar_a_name
nodetool rebuild_index apimodel_v2 apis_revision ar_a_uuid
nodetool rebuild_index apimodel_v2 apis_revision ar_base_url
nodetool rebuild_index apimodel_v2 apis_revision ar_is_active
nodetool rebuild_index apimodel_v2 apis_revision ar_is_latest
nodetool rebuild_index apimodel_v2 apis_revision ar_name
nodetool rebuild_index apimodel_v2 apis_revision ar_org_name
nodetool rebuild_index apimodel_v2 apis_revision ar_rel_ver
nodetool rebuild_index apimodel_v2 apis_revision ar_rev_num
nodetool rebuild_index apimodel_v2 method m_a_name
nodetool rebuild_index apimodel_v2 method m_api_uuid
nodetool rebuild_index apimodel_v2 method m_ar_uuid
nodetool rebuild_index apimodel_v2 method m_base_url
nodetool rebuild_index apimodel_v2 method m_name
nodetool rebuild_index apimodel_v2 method m_org_name
nodetool rebuild_index apimodel_v2 method m_r_name
nodetool rebuild_index apimodel_v2 method m_r_uuid
nodetool rebuild_index apimodel_v2 method m_res_path
nodetool rebuild_index apimodel_v2 method m_rev_num
nodetool rebuild_index apimodel_v2 resource r_a_name
nodetool rebuild_index apimodel_v2 resource r_api_uuid
nodetool rebuild_index apimodel_v2 resource r_ar_uuid
nodetool rebuild_index apimodel_v2 resource r_base_url
nodetool rebuild_index apimodel_v2 resource r_name
nodetool rebuild_index apimodel_v2 resource r_org_name
nodetool rebuild_index apimodel_v2 resource r_res_path
nodetool rebuild_index apimodel_v2 resource r_rev_num
nodetool rebuild_index apimodel_v2 schemas s_api_uuid
nodetool rebuild_index apimodel_v2 schemas s_ar_uuid
nodetool rebuild_index apimodel_v2 security sa_api_uuid
nodetool rebuild_index apimodel_v2 security sa_ar_uuid
nodetool rebuild_index apimodel_v2 template t_a_name
nodetool rebuild_index apimodel_v2 template t_a_uuid
nodetool rebuild_index apimodel_v2 template t_entity
nodetool rebuild_index apimodel_v2 template t_name
nodetool rebuild_index apimodel_v2 template t_org_name
nodetool rebuild_index apimodel_v2 template_auth au_api_uuid

Перестроить индексы для пространства ключей: dek
```
nodetool rebuild_index dek keys usecase_index
```

[Только для монетизации] Перестройте индексы для пространства ключей: mint

nodetool rebuild_index mint limits limits_created_date_idx
nodetool rebuild_index mint limits limits_id_idx
nodetool rebuild_index mint limits limits_org_id_idx
nodetool rebuild_index mint limits limits_updated_date_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_created_date_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_currency_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_dev_id_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_id_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_limit_id_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_org_id_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_prod_id_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_reason_code_idx
nodetool rebuild_index mint suspended_developer_products suspended_developer_products_sub_org_id_idx
nodetool rebuild_index mint invitations invitations_company_id_idx
nodetool rebuild_index mint invitations invitations_created_at_idx
nodetool rebuild_index mint invitations invitations_developer_id_idx
nodetool rebuild_index mint invitations invitations_lastmodified_at_idx
nodetool rebuild_index mint invitations invitations_org_id_idx

[Только для монетизации] Перестройте индексы для пространства ключей: taurus

nodetool rebuild_index taurus triggers triggers_env_idx
nodetool rebuild_index taurus triggers triggers_job_id_idx
nodetool rebuild_index taurus triggers triggers_org_id_idx
nodetool rebuild_index taurus job_details job_details_job_class_name_idx
nodetool rebuild_index taurus job_details job_details_job_group_idx
nodetool rebuild_index taurus job_details job_details_job_name_idx
nodetool rebuild_index taurus org_triggers org_triggers_org_id_idx
nodetool rebuild_index taurus triggers_suite triggers_suite_group_idx
nodetool rebuild_index taurus triggers_suite triggers_suite_name_idx
nodetool rebuild_index taurus triggers_suite triggers_suite_suite_id_idx

[Только для монетизации] Перестройте индексы для пространства ключей: notification

nodetool rebuild_index notification notification_service_item notification_service_item_org_id_idx
nodetool rebuild_index notification notification_service_item notification_service_item_status_idx
nodetool rebuild_index notification notification_service_black_list_item notification_service_black_list_item_org_id_idx
nodetool rebuild_index notification notification_service_black_list_item notification_service_black_list_item_to_email_idx
nodetool rebuild_index notification notification_email_template_item notification_email_template_item_name_idx
nodetool rebuild_index notification notification_email_template_item notification_email_template_item_org_id_idx

Проверка

Чтобы проверить, вступили ли в силу изменения стратегии сжатия в схеме, следуйте инструкциям в Приложении 1.
Убедитесь, что сжатие выполнено успешно и данные сжаты после изменения стратегии:
1. На каждом узле Cassandra выполните следующую команду nodetool, чтобы проверить, завершены ли все сжатия и нет ли ожидающих:
```
nodetool compactionstats
```
2. Убедившись, что уплотнений, ожидающих выполнения, нет, проверьте временную метку последнего изменения файлов данных (в каталоге /opt/apigee/data/apigee-cassandra/data/). Она должна быть более поздней, чем временная метка выполнения CQL-запроса на изменение стратегии уплотнения.

Откат

Если вам нужно выполнить откат, выберите один из следующих вариантов:

Вариант 1. Отменить изменения

Вернитесь к исходной стратегии сжатия.

Выполните в командной строке CQL команды ALTER TABLE, аналогичные тем, которые вы использовали ранее, чтобы изменить стратегию сжатия.

Если вы уже перестраивали индексы при изменении стратегии сжатия на LeveledCompactionStrategy, вам нужно будет перестроить их снова. Выполните те же действия, что и при перестроении всех индексов. Если вы не перестраивали индексы ранее, то не нужно делать этого и при откате.

Вариант 2. Полное восстановление данных из резервной копии

Восстановите данные из резервной копии для всех пространств ключей:

Следуйте инструкциям в статье Как восстановить данные из резервной копии.

Приложение 1. Проверка стратегии сжатия

Стратегии сжатия задаются на уровне таблицы в Cassandra. Чтобы проверить стратегию сжатия для каждой таблицы, используйте запросы ниже.

Вы можете выполнять CQL-запросы в командной строке CQL. Чтобы вызвать подсказку CQL:

/opt/apigee/apigee-cassandra/bin/cqlsh `hostname -i`

Вы увидите ответ, похожий на следующий:

Connected to apigee at XX.XX.XX.XX:9042.
[cqlsh 6.2.0 | Cassandra 5.0.8 | CQL spec 3.4.7 | Native protocol v5]
Use HELP for help.
cqlsh>

Чтобы определить текущую стратегию сжатия, выполните следующие действия:

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

Если для стратегии сжатия задано значение SizeTieredCompactionStrategy, столбец compaction в приведенных ниже запросах будет выглядеть примерно так:

{'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}

Если для стратегии сжатия задано значение LeveledCompactionStrategy, столбец compaction в запросах ниже будет выглядеть примерно так:

{'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}

Чтобы определить стратегию сжатия для каждой таблицы в определенном пространстве ключей, можно выполнить следующие запросы:

select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'kms';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'user_settings';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'keyvaluemap';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'devconnect';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'counter';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'cache';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'auth';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'audit';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'apprepo';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'apimodel_v2';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'identityzone';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'dek';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'analytics';

#If you are using Monetization, check the below as well
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'mint';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'taurus';
select keyspace_name, table_name, compaction from system_schema.tables where keyspace_name = 'notification';