Zmień strategię tworzenia wiadomości Cassandra

Apigee używa bazy danych Cassandra do przechowywania większości danych, w tym danych serwerów proxy, pamięci podręcznych i tokenów. Kompresja to kluczowy proces zmniejszania rozmiaru danych przechowywanych w bazach danych, niezbędny do zapewnienia wydajnego działania baz danych. Cassandra obsługuje różne strategie kompresji. Firma Apigee zaleca, aby wszyscy klienci korzystający z Edge for Private Cloud używali klastrów Cassandra z LeveledCompactionStrategy, a nie domyślnego SizeTieredCompactionStrategy we wszystkich tabelach. LeveledCompactionStrategy zapewnia lepszą wydajność, lepsze wykorzystanie dysku, wydajniejsze kompresowanie i wymaga mniej wolnego miejsca niż SizeTieredCompactionStrategy.

Wszystkie nowe instalacje Apigee w wersji 4.52.02 lub nowszej automatycznie konfigurują Cassandra z użyciem LeveledCompactionStrategy. Jeśli jednak używasz starszej wersji Apigee lub zaktualizowałeś/zaktualizowałaś Apigee 4.53.00 ze starszej wersji, Twoja instalacja może nadal używać Cassandra z SizeTieredCompactionStrategy.

Chociaż nie zaleca się zmiany strategii kompresowania na inną niż LeveledCompactionStrategy, ten dokument zawiera informacje o tym, jak w razie potrzeby wprowadzić tę zmianę, oraz instrukcje sprawdzania bieżącej strategii kompresowania. Zmiana strategii kompresowania na niezalecaną opcję może spowodować, że w przyszłości aktualizacje oprogramowania Cassandra zastąpią Twoje zmiany. Jeśli korzystasz z metody niestandardowej, zalecamy sprawdzanie strategii kompresowania po każdym uaktualnieniu.

Przygotowanie

Sprawdź istniejącą strategię kompresowania

Możesz sprawdzić obecną strategię kompresowania w tabelach, postępując zgodnie z instrukcjami w Dodatku 1. Jeśli strategia kompresji jest już ustawiona na LeveledCompactionStrategy, może to być spowodowane uruchomieniem instalacji OPDK w wersji 4.51 lub nowszej albo wcześniejszą zmianą na LeveledCompactionStrategy zgodnie z zaleceniem Apigee. Jeśli korzystasz już z usługi LeveledCompactionStrategy, Apigee zaleca kontynuowanie tej strategii i unikanie zmian. Jednak Edge for Private Cloud jest obsługiwany przez Ciebie, dlatego z podanych niżej instrukcji dowiesz się, jak w razie potrzeby zmienić strategię kompresowania.

Kopia zapasowa

Zmiana strategii kompresji powoduje uruchomienie pełnego cyklu kompresji w węzłach Cassandra, co może spowodować pewne opóźnienia z powodu obciążenia kompresji i jednoczesnego ruchu aplikacji. Do przywrócenia węzłów Cassandra z kopii zapasowych może być konieczne wycofanie tej zmiany. Aby dowiedzieć się, jak utworzyć kopię zapasową danych przed zmianą strategii kompresowania, przeczytaj sekcję Jak tworzyć kopie zapasowe.

Przepustowość kompresji

Po zmianie strategii kompresowania na LeveledCompactionStrategy kompresowanie może być wykonywane przez przez długi czas. Czas działania może się różnić w zależności od rozmiaru zagęszczonego zbioru danych. Podczas kompresowania Cassandra może zużywać więcej zasobów systemowych. Dzięki temu kompresowanie nie zajmie dużo czasu zasobów systemowych, które mogą zakłócać żądania środowiska wykonawczego API, zalecamy ustawienie limitów dla z przepustowością kompresowania.

Uruchom następujące polecenie nodetool w każdym z węzłów, aby ustawić maksymalną przepustowość kompresowania przy 128 MB we wszystkich węzłach Cassandra:

nodetool setcompactionthroughput 128

Dobieranie rozmiaru maszyn wirtualnych na potrzeby kompresowania

Przed wykonaniem tej zmiany upewnij się, że węzły Cassandra mają wystarczającą liczbę zasobów procesora i pamięci. Przed wykonaniem tej zmiany upewnij się, że żadne węzły Cassandra nie działają z ponad 25% obciążenia procesora.

Po zmianie strategii kompresji powinien zostać uruchomiony pełny cykl kompresji, dlatego zalecamy zmianę strategii kompresji w okresie niskiego natężenia ruchu.

Uruchomienia o różnej długości

Wprowadzanie zmian we wszystkich węzłach w ciągu jednego dnia może być niemożliwe, zwłaszcza jeśli obsługujesz duże klastry Cassandra, ponieważ indeksy trzeba ponownie tworzyć w każdym węźle. Możesz zmienić strategię kompresowania w jednym schemacie lub tylko w jednej tabeli naraz. Aby to zrobić, zmodyfikuj tabelę, aby zmienić jej strategię kompresowania, a następnie ponownie skompiluj wszystkie indeksy w tabeli (jeśli występują) we wszystkich węzłach. Następnie powtórz powyższą procedurę dla każdej tabeli lub spacji. Takie przetwarzanie w przypadku jednej tabeli lub jednej przestrzeni kluczy można podzielić na przetwarzanie w różnych dniach.

Aby na przykład zmienić strategię kompresowania tabeli oauth_20_access_tokens w schemacie kms na LeveledCompactionStrategy, możesz wykonać te czynności:

  1. Zmień tabelę, aby zmienić strategię kompresji, wykonując to zapytanie CQL:

    ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  2. Utwórz ponownie wszystkie indeksy tylko w tej tabeli:

    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   
        

Zmiana strategii kompresowania

Ogólnie rzecz biorąc, zmiana strategii kompresji to 2-etapowy proces:

  1. Zmień strategię kompresji każdej tabeli.
  2. Utwórz po kolei wszystkie indeksy w każdym węźle.

Aby zmodyfikować strategię kompresowania, musisz wykonać polecenie ALTER TABLE pojedynczo w każdej tabeli. Przykładowe polecenie ALTER TABLE wygląda tak:

# 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'};

Zmiana tabeli w celu ustawienia nowej strategii kompresji

Aby zmienić strategię w przypadku jednego klucza przestrzeni nazw naraz, uruchom te zapytania CQL na dowolnym węźle Cassandra. Zapytania CQL można wykonywać w prośbie CQL. Instrukcje wywołania promptu CQL:

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

Połączono z Apigee na porcie XXXXXXXX:9042.

[cqlsh 5.0.1 | Cassandra 3.11.16 | CQL spec 3.4.4 | Native protocol v4]
Use HELP for help.
cqlsh>

Poniższe polecenia obejmują zmianę strategii kompresowania na LeveledCompactionStrategy, ale podobnych poleceń można użyć do zmiany strategii kompresowania.

Poniższe kroki od 14 do 16 mają zastosowanie tylko wtedy, gdy korzystasz z funkcji zarabiania.

  1. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: 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'};
    
  2. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: user_settings
    ALTER TABLE user_settings.user_settings WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  3. Zapytania CQL służące do zmiany strategii kompresji dla przestrzeni kluczy: keyvaluemap
    ALTER TABLE keyvaluemap.keyvaluemaps_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  4. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: 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'};
    
  5. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: 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'};
    
  6. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: cache
    ALTER TABLE cache.cache_entries WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE cache.cache_sequence_id_r24 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  7. Zapytania CQL służące do zmiany strategii kompresji dla przestrzeni kluczy: auth
    ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  8. Zapytania CQL służące do zmiany strategii kompresji dla przestrzeni kluczy: audit
    ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  9. Zapytania CQL służące do zmiany strategii kompresji dla przestrzeni kluczy: 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'};
  10. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: 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'};
  11. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: identityzone
    ALTER TABLE identityzone.IdentityZones WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE identityzone.OrgToIdentityZone WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  12. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: dek
    ALTER TABLE dek.keys WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  13. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: 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'};
  14. [Tylko w przypadku zarabiania] Zapytania CQL służące do zmiany strategii kompresji przestrzeni kluczy: 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'};
  15. [Tylko w przypadku zarabiania] Zapytania CQL służące do zmiany strategii kompresji przestrzeni kluczy: 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'};
  16. [Tylko w przypadku zarabiania] Zapytania CQL służące do zmiany strategii kompresji przestrzeni kluczy: 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'};

Odbuduj indeksy

Ten krok należy wykonać po każdej zmianie strategii kompresji. Na każdym węźle Cassandra uruchom po kolei te polecenia: nodetool.

Kroki 7–9 poniżej dotyczą tylko sytuacji, gdy korzystasz z zarabiania.

  1. Odbuduj indeksy dla przestrzeni kluczy: 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
    
  2. Utwórz indeksy ponownie dla przestrzeni kluczy: 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
    
  3. Odbuduj indeksy dla przestrzeni kluczy: cache

    nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx
    
  4. Odbuduj indeksy dla przestrzeni kluczy: 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
    
  5. Odbuduj indeksy dla przestrzeni kluczy: 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
    
  6. Odbuduj indeksy dla przestrzeni kluczy: dek

    nodetool rebuild_index dek keys usecase_index
    
  7. [Tylko zarabianie] Odbuduj indeksy dla klucza: 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
    
  8. [Tylko zarabianie] Odbuduj indeksy dla klucza: 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
    
  9. [Monetization only] Odbuduj indeksy dla przestrzeni kluczy: 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
    

Weryfikacja

  1. Sprawdź, czy zmiana strategii kompresji w schemacie została zastosowana. Aby to zrobić, wykonaj instrukcje podane w Załączniku 1.
  2. Sprawdź, czy po zmianie strategii udało się uruchomić funkcję Kompresja i czy dane zostały skompresowane:
    1. Na każdym węźle Cassandra uruchom to polecenie nodetool, aby sprawdzić, czy wszystkie kompresje zostały ukończone i czy nie ma żadnych oczekujących:
      nodetool compactionstats
    2. Po sprawdzeniu za pomocą powyższego polecenia, aby sprawdzić, czy nie ma oczekujących kompresowania, sprawdź, kiedy ostatnia zmodyfikowana sygnatura czasowa plików danych (w sekcji /opt/apigee/data/apigee-cassandra/data/) jest po sygnaturze czasowej wykonania zmiany CQL zmiany strategii kompresowania.

Przywróć

Jeśli chcesz cofnąć zmiany, możesz wybrać jedną z tych opcji:

Opcja 1. Cofnij zmianę

Przywróć strategię kompresji do pierwotnej.

Aby zmienić strategię kompresowania, uruchom podobne polecenia ALTER TABLE w wierszu CQL uruchomione wcześniej.

Jeśli indeksy zostały już odbudowane podczas zmiany strategii kompresowania na LeveledCompactionStrategy, musisz ponownie utworzyć indeksy. Wykonaj te same czynności co wcześniej, by odbudować wszystkie indeksy. Jeśli indeksy nie były wcześniej odtwarzane, nie musisz ich ponownie tworzyć podczas cofania zmian.

Opcja 2. Pełne przywrócenie danych z kopii zapasowej

Przywróć dane z kopii zapasowej dla wszystkich obszarów kluczy:

Wykonaj instrukcje przywracania, jak opisano w sekcji Przywracanie z kopii zapasowej.

Załącznik 1. Sprawdź strategię kompresowania

Strategie kompresowania ustawia się na poziomie tabeli w Cassandra. Możesz użyć zapytań poniżej, aby sprawdzić strategię kompresowania w każdej tabeli.

W oknie poleceń CQL możesz uruchamiać zapytania CQL. Aby wywołać prompt CQL:

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

Powinna pojawić się taka odpowiedź:

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>

Możesz określić bieżącą strategię kompresowania w ten sposób:

Każdy wiersz w danych wyjściowych odpowiada tabeli w przestrzeni klawiszy. W każdym wierszu kolumna Kompakt wskazuje strategię kompresowania używaną w tabeli.

  • Jeśli strategia kompresowania jest ustawiona na SizeTieredCompactionStrategy, kolumna compaction w zapytaniach poniżej będzie wyglądać tak:
  • {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
  • Jeśli strategia kompresowania jest ustawiona na LeveledCompactionStrategy, kolumna compaction w zapytaniach poniżej będzie wyglądać tak:
  • {'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}

Poniższe zapytania można uruchamiać w celu określenia strategii kompresowania dla każdej tabeli w konkretnej przestrzeni kluczy:

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';