Apigee использует базу данных Cassandra для хранения большей части своих данных, включая данные для прокси, кешей и токенов. Сжатие — это критически важный процесс уменьшения размера данных, хранящихся в базах данных, необходимый для поддержания эффективности операций с базами данных. Cassandra поддерживает различные стратегии уплотнения. Apigee рекомендует всем клиентам Edge для частного облака использовать свои кластеры Cassandra с LeveledCompactionStrategy
, а не SizeTieredCompactionStrategy
по умолчанию для всех таблиц. LeveledCompactionStrategy
обеспечивает более высокую производительность, улучшенное использование диска, более эффективное сжатие и требует меньше свободного места по сравнению с SizeTieredCompactionStrategy
.
Все новые установки Apigee 4.52.02 или новее автоматически настраивают Cassandra с помощью LeveledCompactionStrategy
. Однако если вы используете более старую версию Apigee или обновили Apigee до версии 4.52.02 со старой версии, ваша установка по-прежнему может использовать Cassandra с SizeTieredCompactionStrategy
.
Хотя не рекомендуется менять стратегию уплотнения на какую-либо другую, кроме LeveledCompactionStrategy
, в этом документе описано, как внести изменения в случае необходимости, и приведены инструкции по проверке текущей стратегии уплотнения. Изменение стратегии сжатия на нерекомендуемый вариант может привести к тому, что будущие обновления программного обеспечения Cassandra перезапишут ваши изменения. Мы рекомендуем проверять стратегию уплотнения после каждого обновления, если вы используете нестандартный подход.
Подготовка
Проверьте существующую стратегию уплотнения
Проверить существующую стратегию уплотнения можно по таблицам, следуя инструкциям в Приложении 1 . Если стратегией сжатия уже является LeveledCompactionStrategy
, это может быть связано с тем, что вы начали с установки OPDK 4.51 или более поздней версии или ранее изменились на LeveledCompactionStrategy
, как рекомендовано Apigee. Если вы уже используете LeveledCompactionStrategy
, Apigee рекомендует продолжать использовать эту стратегию и избегать изменений. Однако, поскольку Edge for Private Cloud управляется вами, в следующих инструкциях объясняется, как при желании изменить стратегию уплотнения.
Резервное копирование
Поскольку изменение стратегии сжатия запускает полный цикл сжатия в узлах Cassandra, это может привести к некоторым задержкам из-за нагрузки сжатия и одновременного трафика приложений. Откат этого изменения может потребоваться для восстановления узлов Cassandra из резервных копий. См. раздел «Как выполнить резервное копирование» , чтобы узнать, как выполнить резервное копирование данных перед изменением стратегии сжатия.
Производительность уплотнения
После изменения стратегии сжатия на LeveledCompactionStrategy
сжатие может выполняться в течение длительного времени. В зависимости от размера сжатия данных время выполнения может различаться. Во время цикла сжатия Cassandra может использовать больше системных ресурсов. Чтобы сжатие не занимало много системных ресурсов и не нарушало запросы среды выполнения API, мы рекомендуем установить ограничения на пропускную способность сжатия.
Запустите следующую команду nodetool
на каждом из узлов, чтобы установить максимальную пропускную способность сжатия в 128 МБ на всех узлах Cassandra:
nodetool setcompactionthroughput 128
Определение размеров виртуальных машин для сжатия
Перед выполнением этого изменения убедитесь, что узлам Cassandra достаточно ресурсов ЦП и памяти. Перед выполнением этого изменения убедитесь, что ни один из узлов 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 LeveledCompactionStrategyALTER TABLE
kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'}; # To change to SizeTieredCompactionStrategyALTER 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 5.0.1 | Cassandra 3.11.16 | CQL spec 3.4.4 | Native protocol v4] 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 .
- Убедитесь, что сжатие выполнено успешно и данные сжимаются после изменения стратегии:
- На каждом узле Cassandra запустите следующую команду nodetool, чтобы проверить, все ли уплотнения завершены и ничего не ожидает:
nodetool compactionstats
- После проверки с помощью приведенной выше команды, чтобы убедиться в отсутствии ожидающих уплотнений, проверьте, чтобы последняя измененная временная метка файлов данных (в разделе
/opt/apigee/data/apigee-cassandra/data/
) находилась после временной метки при изменении стратегии уплотнения CQL. был казнен.
- На каждом узле Cassandra запустите следующую команду nodetool, чтобы проверить, все ли уплотнения завершены и ничего не ожидает:
Откат
Если вам необходимо выполнить откат, вы можете выбрать один из вариантов ниже:
Вариант 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 5.0.1 | Cassandra 3.11.16 | CQL spec 3.4.4 | Native protocol v4] Use HELP for help. cqlsh>
Вы можете определить текущую стратегию уплотнения следующим образом:
Каждая строка вывода относится к таблице в пространстве ключей. Для каждой строки сжатие столбца указывает стратегию уплотнения, используемую таблицей.
- Если для стратегии сжатия установлено значение SizeTieredCompactionStrategy, сжатие столбцов в приведенных ниже запросах будет примерно таким:
- Если для стратегии уплотнения установлено значение LeveledCompactionStrategy, сжатие столбцов в приведенных ниже запросах будет примерно таким:
{'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
{'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';