Zmień strategię tworzenia wiadomości Cassandra

Apigee wykorzystuje bazę danych Cassandra do przechowywania większości danych, w tym danych serwerów proxy, pamięci podręcznych i tokenów. Kompaktowanie to kluczowy proces zmniejszania rozmiaru danych przechowywanych w bazach danych, który jest niezbędny do zapewnienia wydajnego działania baz danych. Metoda Cassandra obsługuje różne strategie kompresowania. Apigee zaleca, aby wszyscy klienci Edge for Private Cloud we wszystkich tabelach obsługiwali klastry Cassandra przy użyciu interfejsu LeveledCompactionStrategy, a nie domyślnego SizeTieredCompactionStrategy. LeveledCompactionStrategy oferuje lepszą wydajność, lepsze wykorzystanie dysku, bardziej efektywne kompresowanie i wymaga mniej wolnego miejsca w porównaniu z wersją SizeTieredCompactionStrategy.

Wszystkie nowe instalacje Apigee w wersji 4.52.02 lub nowszej automatycznie konfigurują Cassandra z użyciem LeveledCompactionStrategy. Jeśli jednak korzystasz ze starszej wersji Apigee lub uaktualnisz ją do wersji 4.52.02 ze starszej wersji, Twoja instalacja może nadal korzystać z 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 kompresowania jest już ustawiona na LeveledCompactionStrategy, może to wynikać z rozpoczęcia instalacji OPDK w wersji 4.51 lub nowszej albo wcześniejszej zmiany wersji na LeveledCompactionStrategy zgodnie z zaleceniami 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 kompresowania aktywuje pełny cykl kompresowania w węzłach Cassandra, dlatego mogą pojawić się pewne opóźnienia ze względu na obciążenie kompresowania i jednoczesny ruch 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ść kompresowania

Po zmianie strategii kompresowania na LeveledCompactionStrategy kompresowanie może być wykonywane przez przez długi czas. W zależności od rozmiaru kompresowania danych środowisko wykonawcze może się różnić. 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 kompresowania powinien zostać uruchomiony pełny cykl kompresowania, dlatego zalecamy zmianę strategii kompresowania w okresach małego ruchu.

Biegi rozłożone w czasie

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 uruchomienia dla 1 tabeli lub 1 przestrzeni kluczy można podzielić na różne dni.

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

  1. Zmodyfikuj tabelę, aby zmienić strategię kompresowania, uruchamiając ten kod 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 kompresowania składa się z 2 etapów:

  1. Zmodyfikuj strategię kompresowania w 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'};

Zmień tabelę, aby ustawić nową strategię kompresowania

Aby zmienić strategię dla 1 przestrzeni kluczy, uruchom poniższe instrukcje CQL w dowolnym węźle Cassandra. Zadania CQL można uruchamiać za pomocą promptu CQL. Instrukcje wywoływania promptu CQL:

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

Połączono z Apigee pod adresem 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. Skrypty CQL służące do zmiany strategii kompresowania 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. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: auth
    ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  8. Skrypty CQL służące do zmiany strategii kompresowania przestrzeni kluczy: audit
    ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  9. Skrypty CQL służące do zmiany strategii kompresowania 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 generowanie przychodu] Listy CQL służące do zmiany strategii kompresowania 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 generowanie przychodu] Listy CQL służące do zmiany strategii kompresowania 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 generowanie przychodu] Kody CQL służące do zmiany strategii kompresowania 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 kompresowania. Uruchom po kolei te polecenia nodetool w każdym węźle Cassandra.

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

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

    nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx
    
  4. Utwórz indeksy ponownie 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. Utwórz indeksy ponownie 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. Utwórz indeksy ponownie dla przestrzeni kluczy: dek

    nodetool rebuild_index dek keys usecase_index
    
  7. [Monetization only] Odbuduj indeksy dla przestrzeni kluczy: 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. [Monetization only] Odbuduj indeksy dla przestrzeni kluczy: 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 kompresowania w schemacie została zastosowana, wykonując instrukcje w Dodatku 1.
  2. Sprawdź, czy kompresowanie się udało, a po zmianie strategii dane są kompresowane:
    1. W każdym węźle Cassandra uruchom to polecenie nodetool, by sprawdzić, czy wszystkie kompresowanie zostało zakończone i nic nie oczekuje:
      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 musisz przywrócić wcześniejszą wersję oprogramowania, możesz wybrać jedną z tych opcji:

Opcja 1. Cofnij zmianę

Przywróć strategię kompresowania do pierwotnej strategii.

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 zostały odtworzone wcześniej, nie musisz odzyskiwać indeksów podczas wycofywania 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.

Zadania CQL możesz uruchamiać z poziomu promptu CQL. Aby wywołać prompt CQL:

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

Zobaczysz odpowiedź podobną do tej:

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