Mengubah strategi pemadatan Cassandra

Apigee menggunakan database Cassandra untuk menyimpan sebagian besar datanya, termasuk data untuk proxy, cache, dan token. Pemadatan adalah proses penting untuk mengurangi ukuran data yang tersimpan dalam database, yang penting untuk mempertahankan operasi database yang efisien. Cassandra mendukung berbagai strategi untuk pemadatan. Apigee merekomendasikan agar semua pelanggan Edge untuk Private Cloud mengoperasikan cluster Cassandra mereka dengan LeveledCompactionStrategy, bukan SizeTieredCompactionStrategy default, untuk semua tabel. LeveledCompactionStrategy menawarkan performa yang lebih baik, penggunaan disk yang lebih baik, pemadatan yang lebih efisien, dan memerlukan lebih sedikit ruang kosong dibandingkan SizeTieredCompactionStrategy.

Semua penginstalan baru Apigee 4.52.02 atau yang lebih baru akan otomatis mengonfigurasi Cassandra dengan LeveledCompactionStrategy. Namun, jika Anda menggunakan Apigee versi lama atau telah mengupgrade ke Apigee 4.52.02 dari versi yang lebih lama, penginstalan Anda mungkin masih menggunakan Cassandra dengan SizeTieredCompactionStrategy.

Meskipun tidak direkomendasikan untuk mengubah strategi pemadatan menjadi selain LeveledCompactionStrategy, dokumen ini menjelaskan cara melakukan perubahan jika perlu dan memberikan petunjuk untuk memeriksa strategi pemadatan Anda saat ini. Mengubah strategi pemadatan ke opsi yang tidak direkomendasikan dapat menyebabkan upgrade software Cassandra mendatang menimpa perubahan Anda. Sebaiknya verifikasi strategi pemadatan setelah setiap upgrade jika Anda menggunakan pendekatan non-standar.

Persiapan

Memeriksa strategi pemadatan yang ada

Anda dapat memeriksa strategi pemadatan yang ada pada tabel dengan mengikuti petunjuk di Lampiran 1. Jika strategi pemadatan sudah LeveledCompactionStrategy, mungkin karena memulai penginstalan OPDK 4.51 atau yang lebih baru, atau sebelumnya telah mengubah ke LeveledCompactionStrategy seperti yang direkomendasikan oleh Apigee. Jika Anda sudah menggunakan LeveledCompactionStrategy, Apigee merekomendasikan untuk melanjutkan strategi ini dan menghindari perubahan. Namun, karena Edge untuk Private Cloud dioperasikan oleh Anda, petunjuk berikut menjelaskan cara mengubah strategi pemadatan jika diinginkan.

Pencadangan

Karena mengubah strategi pemadatan akan memicu siklus pemadatan penuh dalam node Cassandra, perubahan tersebut mungkin menyebabkan beberapa latensi karena beban pemadatan dan traffic aplikasi secara simultan. Rollback perubahan ini mungkin diperlukan untuk memulihkan node Cassandra dari cadangan. Lihat Cara mencadangkan untuk mempelajari cara mencadangkan data sebelum mengubah strategi pemadatan.

Throughput pemadatan

Setelah strategi pemadatan diubah menjadi LeveledCompactionStrategy, pemadatan dapat berjalan dalam waktu yang lama. Bergantung pada ukuran pemadatan data, runtime dapat bervariasi. Selama siklus pemadatan, Cassandra mungkin menggunakan lebih banyak resource sistem. Untuk memastikan pemadatan tidak memakan banyak resource sistem, yang dapat mengganggu permintaan Runtime API, sebaiknya tetapkan batas untuk throughput pemadatan.

Jalankan perintah nodetool berikut di setiap node untuk menetapkan throughput pemadatan maksimal pada 128 MB di semua node Cassandra:

nodetool setcompactionthroughput 128

Mengukur ukuran VM untuk pemadatan

Pastikan node Cassandra memiliki resource CPU dan memori yang cukup sebelum menjalankan perubahan ini. Pastikan tidak ada node Cassandra yang beroperasi pada lebih dari 25% beban CPU sebelum menjalankan perubahan ini.

Setelah perubahan strategi pemadatan, siklus pemadatan penuh diharapkan akan berjalan, sehingga disarankan untuk mengubah strategi pemadatan selama periode lalu lintas rendah.

Lari bergiliran

Anda mungkin tidak dapat menyelesaikan perubahan semua node dalam sehari, terutama jika Anda mengoperasikan cluster Cassandra yang besar, karena indeks harus dibangun ulang pada setiap node satu per satu. Anda dapat mengubah strategi pemadatan satu skema atau satu tabel dalam satu waktu. Untuk itu, ubah tabel agar mengubah strategi pemadatannya, lalu buat ulang semua indeks pada tabel (jika ada) pada semua node. Kemudian ulangi prosedur di atas untuk setiap tabel atau keyspace. Operasi tersebut untuk satu tabel atau satu keyspace dapat diperinci untuk dijalankan di hari yang berbeda.

Misalnya, untuk mengubah strategi pemadatan tabel oauth_20_access_tokens dalam skema kms menjadi LeveledCompactionStrategy, Anda dapat melakukan tindakan berikut:

  1. Ubah tabel untuk mengubah strategi pemadatan dengan menjalankan CQL berikut:

    ALTER TABLE kms.oauth_20_access_tokens WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  2. Buat ulang semua indeks hanya dari tabel ini:

    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   
        

Mengubah strategi pemadatan

Pada tingkat tinggi, mengubah strategi pemadatan merupakan proses dua langkah:

  1. Mengubah strategi pemadatan setiap tabel.
  2. Buat ulang semua indeks pada setiap node satu per satu.

Untuk mengubah strategi pemadatan, Anda harus menjalankan perintah ALTER TABLE di setiap tabel satu per satu. Contoh perintah ALTER TABLE akan terlihat seperti di bawah ini:

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

Mengubah Tabel untuk Menetapkan Strategi Pemadatan Baru

Jalankan CQL berikut pada satu node Cassandra guna mengubah strategi untuk satu keyspace dalam satu waktu. CQL dapat dijalankan di perintah CQL. Petunjuk untuk memanggil prompt CQL:

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

Terhubung ke Apigee di XXXXXXXX:9042.

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

Perintah di bawah ini membahas perubahan Strategi Pemadatan menjadi LeveledCompactionStrategy, tetapi perintah yang serupa dapat digunakan untuk beralih ke strategi pemadatan lainnya.

Langkah 14 hingga 16 di bawah hanya berlaku jika Anda menggunakan monetisasi.

  1. CQL untuk mengubah strategi pemadatan untuk 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 untuk mengubah strategi pemadatan untuk keyspace: user_settings
    ALTER TABLE user_settings.user_settings WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  3. CQL untuk mengubah strategi pemadatan untuk keyspace: keyvaluemap
    ALTER TABLE keyvaluemap.keyvaluemaps_r21 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  4. CQL untuk mengubah strategi pemadatan untuk 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 untuk mengubah strategi pemadatan untuk 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 untuk mengubah strategi pemadatan untuk keyspace: cache
    ALTER TABLE cache.cache_entries WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE cache.cache_sequence_id_r24 WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  7. CQL untuk mengubah strategi pemadatan untuk keyspace: auth
    ALTER TABLE auth.totp WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  8. CQL untuk mengubah strategi pemadatan untuk keyspace: audit
    ALTER TABLE audit.audits WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE audit.audits_ref WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    
  9. CQL untuk mengubah strategi pemadatan untuk 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 untuk mengubah strategi pemadatan untuk 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 untuk mengubah strategi pemadatan untuk keyspace: identityzone
    ALTER TABLE identityzone.IdentityZones WITH compaction = {'class' : 'LeveledCompactionStrategy'};
    ALTER TABLE identityzone.OrgToIdentityZone WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  12. CQL untuk mengubah strategi pemadatan untuk keyspace: dek
    ALTER TABLE dek.keys WITH compaction = {'class' : 'LeveledCompactionStrategy'};
  13. CQL untuk mengubah strategi pemadatan untuk 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. [Khusus monetisasi] CQL untuk mengubah strategi pemadatan untuk 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. [Khusus monetisasi] CQL untuk mengubah strategi pemadatan untuk 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. [Khusus monetisasi] CQL untuk mengubah strategi pemadatan untuk 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'};

Buat Ulang Indeks

Langkah ini perlu dijalankan setelah perubahan strategi pemadatan apa pun. Jalankan perintah nodetool berikut satu per satu di setiap node Cassandra.

Langkah 7 sampai 9 di bawah hanya berlaku jika Anda menggunakan monetisasi.

  1. Buat ulang indeks untuk 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. Buat ulang indeks untuk 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. Buat ulang indeks untuk keyspace: cache

    nodetool rebuild_index cache cache_entries cache_entries_cache_name_idx
    
  4. Buat ulang indeks untuk 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. Buat ulang indeks untuk 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. Buat ulang indeks untuk keyspace: dek

    nodetool rebuild_index dek keys usecase_index
    
  7. [Khusus monetisasi] Buat ulang indeks untuk 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. [Khusus monetisasi] Buat ulang indeks untuk 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. [Khusus monetisasi] Buat ulang indeks untuk 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
    

Verifikasi

  1. Periksa apakah perubahan strategi pemadatan pada skema telah berlaku dengan mengikuti petunjuk di Lampiran 1.
  2. Pastikan Pemadatan telah berhasil berjalan dan data dipadatkan setelah perubahan strategi:
    1. Pada setiap node Cassandra, jalankan perintah nodetool berikut untuk melihat apakah semua pemadatan telah selesai dan tidak ada yang tertunda:
      nodetool compactionstats
    2. Setelah diverifikasi menggunakan perintah di atas untuk memastikan tidak ada pemadatan yang tertunda, periksa stempel waktu file data yang terakhir diubah (di bagian /opt/apigee/data/apigee-cassandra/data/) agar sesuai dengan stempel waktu saat perubahan strategi pemadatan CQL dieksekusi.

Rollback

Jika perlu melakukan rollback, Anda dapat memilih salah satu opsi di bawah ini:

Opsi 1: Kembalikan perubahan

Rollback strategi pemadatan ke strategi yang awalnya Anda miliki.

Jalankan perintah ALTER TABLE serupa pada perintah CQL yang telah Anda jalankan sebelumnya untuk mengubah strategi pemadatan.

Jika telah membuat ulang indeks saat mengubah strategi pemadatan menjadi LeveledCompactionStrategy, Anda harus membuat ulang indeks lagi. Ikuti langkah yang sama seperti sebelumnya untuk membuat ulang semua indeks. Jika indeks tidak dibuat ulang sebelumnya, Anda tidak perlu membuat ulang indeks selama rollback.

Opsi 2: Pemulihan data sepenuhnya dari cadangan

Memulihkan data dari cadangan untuk semua keyspace:

Ikuti petunjuk untuk memulihkan seperti yang didokumentasikan dalam Memulihkan dari cadangan.

Lampiran 1: Memeriksa strategi pemadatan

Strategi pemadatan ditetapkan pada tingkat tabel di Cassandra. Anda dapat menggunakan kueri di bawah ini untuk memeriksa strategi pemadatan setiap tabel.

Anda dapat menjalankan CQL di prompt CQL. Untuk memanggil perintah CQL:

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

Anda akan melihat respons seperti berikut:

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>

Anda dapat menentukan strategi pemadatan saat ini sebagai berikut:

Setiap baris dalam {i>output<i} berkaitan dengan tabel dalam keyspace. Untuk setiap baris, kolom pemadatan menunjukkan strategi pemadatan yang digunakan oleh tabel.

  • Jika strategi pemadatan ditetapkan ke SizeTieredCompactionStrategy, kolom pemadatan dalam kueri di bawah akan menjadi seperti ini:
  • {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
  • Jika strategi pemadatan ditetapkan ke LeveledCompactionStrategy, kolom pemadatan dalam kueri di bawah akan menjadi seperti ini:
  • {'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}

Kueri di bawah dapat dijalankan untuk menentukan strategi pemadatan setiap tabel di keyspace tertentu:

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