Modifier la stratégie de compactage de Cassandra

Apigee utilise la base de données Cassandra pour stocker la plupart de ses données, y compris les données des proxys, des caches et des jetons. Le compactage est un processus essentiel pour réduire la taille des données stockées dans les bases de données, essentiel pour assurer l'efficacité des opérations de base de données. Cassandra prend en charge différentes stratégies de compaction. Apigee recommande à tous les clients Edge pour Private Cloud d'utiliser LeveledCompactionStrategy pour toutes les tables, plutôt que SizeTieredCompactionStrategy par défaut, pour leurs clusters Cassandra. LeveledCompactionStrategy offre de meilleures performances, une utilisation du disque améliorée, des compactions plus efficaces et nécessite moins d'espace libre que SizeTieredCompactionStrategy.

Toute nouvelle installation d'Apigee 4.52.02 ou d'une version ultérieure configure automatiquement Cassandra avec LeveledCompactionStrategy. Toutefois, si vous utilisez une ancienne version d'Apigee ou que vous êtes passé à Apigee 4.53.00 à partir d'une version antérieure, votre installation peut toujours utiliser Cassandra avec SizeTieredCompactionStrategy.

Bien qu'il ne soit pas recommandé de modifier la stratégie de compaction en autre chose que LeveledCompactionStrategy, ce document explique comment procéder si nécessaire et fournit des instructions pour vérifier votre stratégie de compaction actuelle. Si vous remplacez la stratégie de compaction par une option non recommandée, vos modifications risquent d'être écrasées lors de futures mises à niveau du logiciel Cassandra. Nous vous recommandons de vérifier votre stratégie de compaction après chaque mise à niveau si vous utilisez une approche non standard.

Préparation

Vérifier la stratégie de compaction existante

Pour vérifier la stratégie de compaction existante sur les tables, suivez les instructions de l'annexe 1. Si la stratégie de compactage est déjà LeveledCompactionStrategy, cela peut être dû au début d'une installation d'OPDK 4.51 ou version ultérieure, ou au passage à LeveledCompactionStrategy conformément aux recommandations d'Apigee. Si vous utilisez déjà LeveledCompactionStrategy, Apigee vous recommande de poursuivre cette stratégie et d'éviter les modifications. Cependant, comme Edge for Private Cloud est exploité par vous, les instructions suivantes expliquent comment modifier la stratégie de compactage si vous le souhaitez.

Sauvegarde

Étant donné que la modification de la stratégie de compaction déclenche un cycle de compaction complet dans les nœuds Cassandra, elle peut entraîner des latences en raison de la charge des compactions et du trafic d'application simultané. Vous devrez peut-être annuler cette modification pour restaurer les nœuds Cassandra à partir de sauvegardes. Consultez Comment sauvegarder pour savoir comment sauvegarder vos données avant de modifier la stratégie de compaction.

Débit de compactage

Une fois la stratégie de compaction définie sur LeveledCompactionStrategy, les compactions peuvent s'exécuter pendant une longue période. La durée d'exécution peut varier en fonction de la taille du compactage des données. Pendant le cycle de compaction, Cassandra peut utiliser plus de ressources système. Pour s'assurer que le compactage n'occupe pas beaucoup de ressources système pouvant perturber les requêtes d'exécution des API, nous vous recommandons de définir des limites le débit de compactage.

Exécutez la commande nodetool suivante sur chacun des nœuds pour définir le débit de compaction sur 128 Mo maximum sur tous les nœuds Cassandra :

nodetool setcompactionthroughput 128

Dimensionner des VM pour le compactage

Assurez-vous que les nœuds Cassandra disposent de suffisamment de ressources processeur et de mémoire avant d'effectuer cette modification. Avant d'effectuer cette modification, assurez-vous qu'aucun nœud Cassandra n'utilise plus de 25 % de la charge de processeur.

Après un changement de stratégie de compaction, un cycle de compaction complet doit s'exécuter. Nous vous recommandons donc de modifier la stratégie de compaction pendant les périodes de faible trafic.

Courses échelonnées

Il se peut que vous ne puissiez pas procéder au changement de tous les nœuds en une journée, en particulier si vous exploitez de grands clusters Cassandra, car les index doivent être recréés sur chaque nœud un par un. Vous pouvez modifier la stratégie de compaction d'un schéma ou d'une table à la fois. Pour ce faire, modifiez la table pour modifier sa stratégie de compaction, puis reconstruisez tous les indices de la table (le cas échéant) sur tous les nœuds. Répétez ensuite la procédure ci-dessus pour chaque table ou espace de clés. Ces exécutions pour une table ou un espace de clés peuvent être réparties sur plusieurs jours.

Par exemple, pour remplacer la stratégie de compaction de la table oauth_20_access_tokens dans le schéma kms par LeveledCompactionStrategy, procédez comme suit :

  1. Modifiez la table pour modifier la stratégie de compaction en exécutant la requête CQL suivante :

    ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};

  2. Recompilez tous les indices de cette table uniquement :

    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

Modifier la stratégie de compaction

De manière générale, la modification de la stratégie de compaction se fait en deux étapes :

  1. Modifiez la stratégie de compaction de chaque table.
  2. Reconstruisez tous les index de chaque nœud un par un.

Pour modifier la stratégie de compactage, vous devez exécuter une commande ALTER TABLE sur chaque table une par une. Voici un exemple de commande ALTER TABLE:

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

Modifier la table pour définir une nouvelle stratégie de compaction

Exécutez les requêtes CQL suivantes sur un nœud Cassandra pour modifier la stratégie d'un espace de clés à la fois. Les requêtes CQL peuvent être exécutées dans l'invite CQL. Instructions pour appeler l'invite CQL:

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

Connecté à Apigee à l'adresse XXXXXXXX:9042.

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

Les commandes ci-dessous permettent de définir la stratégie de compactage sur LeveledCompactionStrategy, mais vous pouvez utiliser des commandes similaires pour passer à d'autres stratégies de compactage.

Les étapes 14 à 16 ci-dessous ne s'appliquent que si vous utilisez la monétisation.

  1. Les CQL vont modifier la stratégie de compactage pour l'espace de clés: 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. Les CQL vont modifier la stratégie de compactage pour l'espace de clés: user_settings 
    ALTER TABLE user_settings.user_settings WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  3. Instructions CQL pour modifier la stratégie de compaction du keyspace : keyvaluemap 
    ALTER TABLE keyvaluemap.keyvaluemaps_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  4. Instructions CQL pour modifier la stratégie de compaction du 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. Les CQL vont modifier la stratégie de compactage pour l'espace de clés: 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. Les CQL vont modifier la stratégie de compactage pour l'espace de clés: cache 
    ALTER TABLE cache.cache_entries WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE cache.cache_sequence_id_r24 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  7. Instructions CQL pour modifier la stratégie de compaction du keyspace : auth 
    ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  8. Instructions CQL pour modifier la stratégie de compaction du keyspace : audit 
    ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  9. Instructions CQL pour modifier la stratégie de compaction du 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. Instructions CQL pour modifier la stratégie de compaction du 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. Instructions CQL pour modifier la stratégie de compaction du keyspace : identityzone 
    ALTER TABLE identityzone.IdentityZones WITH compaction = {'class' : 'LeveledCompactionStrategy'};
ALTER TABLE identityzone.OrgToIdentityZone WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  12. Les CQL vont modifier la stratégie de compactage pour l'espace de clés: dek 
    ALTER TABLE dek.keys WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  13. Instructions CQL pour modifier la stratégie de compaction du 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. [Monétisation uniquement] Requêtes CQL pour modifier la stratégie de compaction du 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. [Monétisation uniquement] Requêtes CQL pour modifier la stratégie de compaction du 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. [Monétisation uniquement] Requêtes CQL pour modifier la stratégie de compaction du 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'};

Recompiler des index

Cette étape doit être exécutée après toute modification de stratégie de compactage. Veuillez exécuter les commandes nodetool suivantes une par une sur chaque nœud Cassandra.

Les étapes 7 à 9 ci-dessous ne s'appliquent que si vous utilisez la monétisation.

  1. Recréer les index pour l'espace de clés : 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. Recréer les index pour l'espace de clés : 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. Recréer les index pour l'espace de clés : cache

    nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx

  4. Reconstruire les index pour l'espace de clés: 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. Reconstruire les index pour l'espace de clés: 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. Recréer les index pour l'espace de clés : dek

    nodetool rebuild_index dek keys usecase_index

  7. [Monétisation uniquement] Recréer des indices pour l'espace de clés : 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. [Monétisation uniquement] Reconstruction des index pour l'espace de clés: 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. [Monétisation uniquement] Reconstruction des index pour l'espace de clés: 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

Validation

  1. Vérifiez que la modification de la stratégie de compactage sur le schéma a été appliquée en suivant les instructions de l'annexe 1.
  2. Vérifiez que le compactage a bien été exécuté et que les données sont compactes après le changement de stratégie: <ph type="x-smartling-placeholder">
      </ph>
    1. Sur chaque nœud Cassandra, exécutez la commande nodetool suivante pour vérifier si toutes les compactions sont terminées et si rien n'est en attente : 
      nodetool compactionstats
    2. Une fois que vous avez vérifié à l'aide de la commande ci-dessus qu'aucune compaction n'est en attente, vérifiez que l'horodatage de la dernière modification des fichiers de données (sous /opt/apigee/data/apigee-cassandra/data/) est postérieur à l'horodatage de l'exécution de la requête CQL de modification de la stratégie de compaction.

Rollback

Si vous devez effectuer un rollback, vous pouvez choisir l'une des options ci-dessous:

Option 1: Annuler la modification

Revenez à la stratégie de compaction que vous aviez initialement.

Exécutez des commandes ALTER TABLE similaires dans l'invite CQL que vous avez exécutée précédemment pour modifier la stratégie de compaction.

Si vous aviez déjà reconstruit les index en changeant la stratégie de compactage à LeveledCompactionStrategy, vous devrez reconstruire les index. Suivez la même procédure que précédemment pour reconstruire tous les index. Si vous n'avez pas recompilé les index précédemment, vous n'avez pas besoin de le faire lors du rollback.

Option 2 : Restauration complète des données à partir d'une sauvegarde

Restaurer les données à partir d'une sauvegarde pour tous les espaces de clés :

Veuillez suivre les instructions de la section Restaurer à partir d'une sauvegarde.

Annexe 1 : Vérifier la stratégie de compaction

Les stratégies de compaction sont définies au niveau de la table dans Cassandra. Vous pouvez utiliser les requêtes ci-dessous pour vérifier la stratégie de compactage pour chaque table.

Vous pouvez exécuter des requêtes CQL à l'invite CQL. Pour appeler l'invite CQL :

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

Un résultat semblable à celui-ci s'affiche:

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>

Vous pouvez déterminer la stratégie de compaction actuelle comme suit :

Chaque ligne de la sortie se rapporte à une table dans un espace de clés. Pour chaque ligne, la colonne compaction indique la stratégie de compaction utilisée par la table.

  • Si la stratégie de compaction est définie sur SizeTieredCompactionStrategy, la colonne compaction des requêtes ci-dessous se présente comme suit :
    • {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
  • Si la stratégie de compaction est définie sur LeveledCompactionStrategy, la colonne compaction des requêtes ci-dessous se présente comme suit :
    • {'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}

Vous pouvez exécuter les requêtes ci-dessous pour déterminer la stratégie de compaction pour chaque table d'un espace de clés particulier :

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