Cambiare la strategia di compattazione di Cassandra

Apigee utilizza il database Cassandra per archiviare la maggior parte dei suoi dati, inclusi i dati per proxy, cache e token. La compattazione è un processo fondamentale per ridurre le dimensioni dei dati archiviati nei database, essenziale per mantenere efficienti le operazioni del database. Cassandra supporta varie strategie di compattazione. Apigee consiglia a tutti i clienti di Edge for Private Cloud di utilizzare i cluster Cassandra con LeveledCompactionStrategy, anziché la SizeTieredCompactionStrategy predefinita, per tutte le tabelle. LeveledCompactionStrategy offre prestazioni migliori, un utilizzo del disco migliorato, compattazioni più efficienti e richiede meno spazio libero rispetto a SizeTieredCompactionStrategy.

Tutte le nuove installazioni di Edge for Private Cloud 4.52.02 o versioni successive configurano automaticamente Cassandra con LeveledCompactionStrategy. Tuttavia, se hai eseguito l'upgrade a Edge for Private Cloud 4.54.00 da una versione precedente, l'installazione potrebbe ancora utilizzare Cassandra con SizeTieredCompactionStrategy.

Sebbene non sia consigliabile modificare la strategia di compattazione in un'opzione diversa da LeveledCompactionStrategy, questo documento descrive come apportare la modifica, se necessario, e fornisce istruzioni per controllare la strategia di compattazione attuale. Se modifichi la strategia di compattazione in un'opzione non consigliata, i futuri upgrade del software Cassandra potrebbero sovrascrivere le modifiche. Ti consigliamo di verificare la strategia di compattazione dopo ogni upgrade se utilizzi un approccio non standard.

Preparazione

Prerequisiti

In Edge for Private Cloud 4.54.00, Cassandra 5.x richiede JDK 17 (Java 17). Prima di eseguire i com0/}andi cqlsh su un nodo Cassandra, assicurati che Java 17 sia configurato come versione Java predefinita (ad esempio, eseguendo sudo alternatives --set java JAVA_17_PATH/bin/java o impostando JAVA_HOME sull'installazione di JDK 17).nodetool

Controlla la strategia di compattazione esistente

Puoi controllare la strategia di compattazione esistente nelle tabelle seguendo le istruzioni riportate nell'Appendice 1. Se la strategia di compattazione è già LeveledCompactionStrategy, potrebbe essere dovuto all'utilizzo di un'installazione di Edge for Private Cloud 4.51 o versioni successive oppure alla modifica precedente in LeveledCompactionStrategy come consigliato da Apigee. Se utilizzi già LeveledCompactionStrategy, Apigee consiglia di continuare con questa strategia ed evitare modifiche. Tuttavia, poiché Edge for Private Cloud è gestito da te, le seguenti istruzioni spiegano come modificare la strategia di compattazione, se lo desideri.

Backup

Poiché la modifica della strategia di compattazione attiva un ciclo di compattazione completo nei nodi Cassandra, potrebbe introdurre alcune latenze dovute al carico delle compattazioni e al traffico simultaneo delle applicazioni. Il rollback di questa modifica non richiede il ripristino da un backup; puoi ripristinare direttamente la strategia di compattazione come descritto in Opzione 1: ripristina la modifica. Tuttavia, per precauzione, consulta Come eseguire il backup dei dati prima di modificare la strategia di compattazione.

Throughput di compattazione

Dopo aver modificato la strategia di compattazione in LeveledCompactionStrategy, le compattazioni potrebbero essere eseguite per un periodo di tempo prolungato. A seconda delle dimensioni della compattazione dei dati, il tempo di esecuzione può variare. Durante il ciclo di compattazione Cassandra potrebbe utilizzare più risorse di sistema. Per assicurarti che la compattazione non utilizzi molte risorse di sistema, il che potrebbe interrompere le richieste di runtime API, ti consigliamo di impostare limiti per il throughput di compattazione.

Esegui il seguente nodetool comando su ciascuno dei nodi per impostare il throughput di compattazione al massimo a 128 MB su tutti i nodi Cassandra:

nodetool setcompactionthroughput 128

Ridimensiona le VM per le compattazioni

Prima di eseguire questa modifica, assicurati che i nodi Cassandra dispongano di risorse di CPU e memoria sufficienti e che operino con un carico di CPU non superiore al 25%.

Dopo una modifica della strategia di compattazione, è previsto l'esecuzione di un ciclo di compattazione completo, pertanto ti consigliamo di modificare la strategia di compattazione durante i periodi di traffico ridotto.

Esecuzioni scaglionate

Potresti non essere in grado di completare la modifica di tutti i nodi entro un giorno, soprattutto se utilizzi cluster Cassandra di grandi dimensioni, poiché gli indici devono essere ricreati su ogni nodo uno alla volta. Puoi modificare la strategia di compattazione di uno schema o di una tabella alla volta. A questo scopo, modifica la tabella per cambiarne la strategia di compattazione e poi ricrea tutti gli indici della tabella (se presenti) su tutti i nodi. Quindi ripeti la procedura descritta sopra per ogni tabella o keyspace. Queste esecuzioni per una tabella o un keyspace possono essere suddivise in modo da essere eseguite in giorni diversi.

Ad esempio, per modificare la strategia di compattazione della tabella oauth_20_access_tokens nello schema kms in LeveledCompactionStrategy, puoi procedere nel seguente modo:

  1. Modifica la tabella per cambiare la strategia di compattazione eseguendo il seguente CQL:

    ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  2. Ricrea tutti gli indici solo di questa tabella:

    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   
        

Modifica della strategia di compattazione

In linea generale, la modifica della strategia di compattazione è un processo in due passaggi:

  1. Modifica la strategia di compattazione di ogni tabella.
  2. Ricrea tutti gli indici su ogni nodo uno alla volta.

Per modificare la strategia di compattazione, devi eseguire un comando ALTER TABLE su ogni tabella una alla volta. Un comando ALTER TABLE di esempio è simile al seguente:

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

Modifica la tabella per impostare la nuova strategia di compattazione

Esegui i seguenti CQL su un nodo Cassandra qualsiasi per modificare la strategia per un keyspace alla volta. I CQL possono essere eseguiti al prompt CQL. Istruzioni per richiamare il prompt CQL:

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

Connessione ad Apigee all'indirizzo XXXXXXXX:9042.

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

I comandi riportati di seguito riguardano la modifica della strategia di compattazione in LeveledCompactionStrategy, ma è possibile utilizzare comandi simili per passare ad altre strategie di compattazione.

I passaggi da 14 a 16 riportati di seguito sono applicabili solo se utilizzi la monetizzazione.

  1. CQL per modificare la strategia di compattazione per il keyspace: 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. CQL per modificare la strategia di compattazione per il keyspace: user_settings
    ALTER TABLE user_settings.user_settings WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  3. CQL per modificare la strategia di compattazione per il keyspace: keyvaluemap
    ALTER TABLE keyvaluemap.keyvaluemaps_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  4. CQL per modificare la strategia di compattazione per il keyspace: 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. CQL per modificare la strategia di compattazione per il keyspace: 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. CQL per modificare la strategia di compattazione per il keyspace: cache
    ALTER TABLE cache.cache_entries WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE cache.cache_sequence_id_r24 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  7. CQL per modificare la strategia di compattazione per il keyspace: auth
    ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  8. CQL per modificare la strategia di compattazione per il keyspace: audit
    ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  9. CQL per modificare la strategia di compattazione per il keyspace: 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. CQL per modificare la strategia di compattazione per il keyspace: 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. CQL per modificare la strategia di compattazione per il keyspace: identityzone
    ALTER TABLE identityzone.IdentityZones WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE identityzone.OrgToIdentityZone WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  12. CQL per modificare la strategia di compattazione per il keyspace: dek
    ALTER TABLE dek.keys WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  13. CQL per modificare la strategia di compattazione per il keyspace: 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. [Solo monetizzazione] CQL per modificare la strategia di compattazione per il keyspace: 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. [Solo monetizzazione] CQL per modificare la strategia di compattazione per il keyspace: 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. [Solo monetizzazione] CQL per modificare la strategia di compattazione per il keyspace: 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'};

Ricrea gli indici

Questo passaggio deve essere eseguito dopo qualsiasi modifica della strategia di compattazione. Esegui i seguenti nodetool comandi uno alla volta su ogni nodo Cassandra.

I passaggi da 7 a 9 riportati di seguito sono applicabili solo se utilizzi la monetizzazione.

  1. Ricrea gli indici per il keyspace: 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. Ricrea gli indici per il keyspace: 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. Ricrea gli indici per il keyspace: cache

    nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx
    
  4. Ricrea gli indici per il keyspace: 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. Ricrea gli indici per il keyspace: 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. Ricrea gli indici per il keyspace: dek

    nodetool rebuild_index dek keys usecase_index
    
  7. [Solo monetizzazione] Ricrea gli indici per il keyspace: 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. [Solo monetizzazione] Ricrea gli indici per il keyspace: 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. [Solo monetizzazione] Ricrea gli indici per il keyspace: 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
    

Verifica

  1. Verifica che la modifica della strategia di compattazione nello schema sia diventata effettiva seguendo le istruzioni riportate nell'Appendice 1.
  2. Verifica che la compattazione sia stata eseguita correttamente e che i dati siano compattati dopo la modifica della strategia:
    1. Su ogni nodo Cassandra, esegui il seguente comando nodetool per verificare se tutte le compattazioni sono state completate e se non sono in attesa:
      nodetool compactionstats
    2. Una volta verificato utilizzando il comando riportato sopra che non sono in attesa compattazioni, controlla che il timestamp dell'ultima modifica dei file di dati (in /opt/apigee/data/apigee-cassandra/data/) sia successivo al timestamp di esecuzione del CQL di modifica della strategia di compattazione.

Esegui il rollback

Se devi eseguire un rollback, puoi scegliere una delle seguenti opzioni:

Opzione 1: ripristina la modifica

Esegui il rollback della strategia di compattazione alla strategia originale.

Esegui comandi ALTER TABLE simili al prompt CQL che hai eseguito in precedenza per modificare la strategia di compattazione.

Se hai già ricreato gli indici durante la modifica della strategia di compattazione in LeveledCompactionStrategy, dovrai ricrearli di nuovo. Segui gli stessi passaggi precedenti per ricreare tutti gli indici. Se non hai ricreato gli indici in precedenza, non devi ricrearli durante il rollback.

Opzione 2: ripristino completo dei dati dal backup

Ripristina i dati dal backup per tutti i keyspace:

Segui le istruzioni per il ripristino come descritto in Esegui il ripristino da un backup.

Appendice 1: controlla la strategia di compattazione

Le strategie di compattazione vengono impostate a livello di tabella in Cassandra. Puoi utilizzare le query riportate di seguito per controllare la strategia di compattazione per ogni tabella.

Puoi eseguire i CQL al prompt CQL. Per richiamare il prompt CQL:

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

Verrà visualizzata una risposta simile alla seguente:

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>

Puoi determinare la strategia di compattazione attuale nel seguente modo:

Ogni riga dell'output si riferisce a una tabella all'interno di un keyspace. Per ogni riga, la colonna compaction indica la strategia di compattazione utilizzata dalla tabella.

  • Se la strategia di compattazione è impostata su SizeTieredCompactionStrategy, la colonna compaction nelle query riportate di seguito sarà simile alla seguente:
  • {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
  • Se la strategia di compattazione è impostata su LeveledCompactionStrategy, la colonna compaction nelle query riportate di seguito sarà simile alla seguente:
  • {'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}

È possibile eseguire le seguenti query per determinare la strategia di compattazione per ogni tabella in un keyspace specifico:

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