Mengumpulkan log Apache Cassandra
Versi Parser: 4.0
Dokumen ini menjelaskan cara menyerap log Apache Cassandra ke Google Security Operations menggunakan agen Bindplane.
Apache Cassandra membuat log untuk operasi database, peristiwa cluster, dan aktivitas sistem. Parser mengekstrak kolom menggunakan pola grok dan filter JSON, lalu memetakannya ke Model Data Terpadu (UDM).
Sebelum memulai
Pastikan Anda memiliki prasyarat berikut:
- Instance Google SecOps
- Windows Server 2016 atau yang lebih baru, atau host Linux dengan
systemd - Konektivitas jaringan antara agen Bindplane dan host Apache Cassandra
- Jika beroperasi dari balik proxy, pastikan port firewall terbuka sesuai dengan persyaratan agen Bindplane
- Akses administratif (SSH) ke host Apache Cassandra
Mendapatkan file autentikasi penyerapan Google SecOps
- Login ke konsol Google SecOps.
- Buka Setelan SIEM > Agen Pengumpulan.
- Download File Autentikasi Penyerapan
Simpan file dengan aman di sistem tempat agen BindPlane akan diinstal.
Mendapatkan ID pelanggan Google SecOps
- Login ke konsol Google SecOps.
- Buka Setelan SIEM > Profil.
Salin dan simpan ID Pelanggan dari bagian Detail Organisasi.
Menginstal agen Bindplane
Instal agen Bindplane di sistem operasi Windows atau Linux Anda sesuai dengan petunjuk berikut.
Penginstalan Windows
- Buka Command Prompt atau PowerShell sebagai administrator.
Jalankan perintah berikut:
msiexec /i "https://github.com/observIQ/bindplane-agent/releases/latest/download/observiq-otel-collector.msi" /quietTunggu hingga penginstalan selesai.
Verifikasi penginstalan dengan menjalankan:
sc query observiq-otel-collectorLayanan akan ditampilkan sebagai RUNNING.
Penginstalan Linux
- Buka terminal dengan hak istimewa root atau sudo.
Jalankan perintah berikut:
sudo sh -c "$(curl -fsSlL https://github.com/observiq/bindplane-agent/releases/latest/download/install_unix.sh)" install_unix.shTunggu hingga penginstalan selesai.
Verifikasi penginstalan dengan menjalankan:
sudo systemctl status observiq-otel-collectorLayanan akan ditampilkan sebagai aktif (berjalan).
Referensi penginstalan tambahan
Untuk opsi penginstalan dan pemecahan masalah tambahan, lihat Panduan penginstalan agen BindPlane.
Mengonfigurasi agen Bindplane untuk menyerap syslog dan mengirimkannya ke Google SecOps
Cari file konfigurasi
Linux:
sudo nano /etc/bindplane-agent/config.yamlWindows:
notepad "C:\Program Files\observIQ OpenTelemetry Collector\config.yaml"
Edit file konfigurasi
Ganti seluruh konten
config.yamldengan konfigurasi berikut:receivers: udplog: listen_address: "0.0.0.0:514" exporters: chronicle/cassandra: compression: gzip creds_file_path: '/etc/bindplane-agent/ingestion-auth.json' customer_id: '<customer_id>' endpoint: malachiteingestion-pa.googleapis.com log_type: CASSANDRA raw_log_field: body service: pipelines: logs/cassandra_to_chronicle: receivers: - udplog exporters: - chronicle/cassandra
Parameter konfigurasi
Ganti placeholder berikut:
Konfigurasi penerima:
listen_address: Alamat IP dan port yang akan diproses:0.0.0.0untuk mendengarkan di semua antarmuka (direkomendasikan)- Port
514adalah port syslog standar (memerlukan root di Linux; gunakan1514untuk non-root)
Konfigurasi eksportir:
creds_file_path: Jalur lengkap ke file autentikasi penyerapan:- Linux:
/etc/bindplane-agent/ingestion-auth.json - Windows:
C:\Program Files\observIQ OpenTelemetry Collector\ingestion-auth.json
- Linux:
customer_id: ID Pelanggan yang disalin dari konsol Google SecOpsendpoint: URL endpoint regional:- Amerika Serikat:
malachiteingestion-pa.googleapis.com - Eropa:
europe-malachiteingestion-pa.googleapis.com - Asia:
asia-southeast1-malachiteingestion-pa.googleapis.com - Lihat Endpoint Regional untuk mengetahui daftar lengkapnya
- Amerika Serikat:
Simpan file konfigurasi
- Setelah mengedit, simpan file:
- Linux: Tekan
Ctrl+O, laluEnter, laluCtrl+X - Windows: Klik File > Save
- Linux: Tekan
Mulai ulang agen Bindplane untuk menerapkan perubahan
Untuk memulai ulang agen Bindplane di Linux, jalankan perintah berikut:
sudo systemctl restart observiq-otel-collectorPastikan layanan sedang berjalan:
```bash sudo systemctl status observiq-otel-collector ```Periksa log untuk mengetahui error:
```bash sudo journalctl -u observiq-otel-collector -f ```
Untuk memulai ulang agen Bindplane di Windows, pilih salah satu opsi berikut:
Command Prompt atau PowerShell sebagai administrator:
net stop observiq-otel-collector && net start observiq-otel-collectorKonsol layanan:
- Tekan
Win+R, ketikservices.msc, lalu tekan Enter. - Temukan observIQ OpenTelemetry Collector.
- Klik kanan, lalu pilih Mulai Ulang.
Pastikan layanan sedang berjalan:
sc query observiq-otel-collectorPeriksa log untuk mengetahui error:
type "C:\Program Files\observIQ OpenTelemetry Collector\log\collector.log"
- Tekan
Mengonfigurasi ekspor syslog di Apache Cassandra
- Login ke host Apache Cassandra menggunakan SSH.
Buka file konfigurasi
logback.xml:- Apache Cassandra (sebagian besar versi):
$(CASSANDRA_HOME)/conf - Datastax Enterprise (penginstalan paket):
/etc/dse - Datastax Enterprise (penginstalan tar):
$(TARBALL_ROOT)/resources/cassandra/conf
- Apache Cassandra (sebagian besar versi):
Tambahkan definisi Appender berikut ke file
logback.xmldi Baris 28:<appender name="SYSLOG" class="ch.qos.logback.classic.net.SyslogAppender"> <syslogHost>BINDPLANE_IP</syslogHost> <port>BINDPLANE_PORT</port> <facility>LOCAL7</facility> <throwableExcluded>true</throwableExcluded> <suffixPattern>%thread:%level:%logger{36}:%msg</suffixPattern> </appender>Ganti
BINDPLANE_IPdanBINDPLANE_PORTdengan alamat IP dan port agen Bindplane yang sebenarnya.Tambahkan kode berikut ke blok logger root
<root level="INFO">di filelogback.xml:Lokasi tempat baris ini disisipkan bergantung pada versi Apache Cassandra Anda:
- Apache Cassandra 5.0.x, Baris 123
- Apache Cassandra 4.0.x dan 4.1.x, Baris 115
- Apache Cassandra 3.11.x dan 3.0.x, Baris 92
- Datastax Enterprise (semua versi), Baris 121
<appender-ref ref="SYSLOG" />
Tabel pemetaan UDM
| Kolom Log | Pemetaan UDM | Logika |
|---|---|---|
agent.ephemeral_id |
observer.labels.value |
Nilai agent.ephemeral_id dari pesan JSON dalam. |
agent.hostname |
observer.hostname |
Nilai agent.hostname dari pesan JSON dalam. |
agent.id |
observer.asset_id |
Penggabungan filebeat: dan nilai agent.id dari pesan JSON dalam. |
agent.name |
observer.user.userid |
Nilai agent.name dari pesan JSON dalam. |
agent.type |
observer.application |
Nilai agent.type dari pesan JSON dalam. |
agent.version |
observer.platform_version |
Nilai agent.version dari pesan JSON dalam. |
cloud.availability_zone |
principal.cloud.availability_zone |
Nilai cloud.availability_zone dari pesan JSON dalam. |
cloud.instance.id |
principal.resource.product_object_id |
Nilai cloud.instance.id dari pesan JSON dalam. |
cloud.instance.name |
principal.resource.name |
Nilai cloud.instance.name dari pesan JSON dalam. |
cloud.machine.type |
principal.resource.attribute.labels.value |
Nilai cloud.machine.type dari pesan JSON dalam, dengan key yang sesuai adalah machine_type. |
cloud.provider |
principal.resource.attribute.labels.value |
Nilai cloud.provider dari pesan JSON dalam, dengan key yang sesuai adalah provider. |
event_metadata._id |
metadata.product_log_id |
Nilai event_metadata._id dari pesan JSON dalam. |
event_metadata.version |
metadata.product_version |
Nilai event_metadata.version dari pesan JSON dalam. |
host.architecture |
target.asset.hardware.cpu_platform |
Nilai host.architecture dari pesan JSON dalam. |
host.fqdn |
target.administrative_domain |
Nilai host.fqdn dari pesan JSON dalam. |
host.hostname |
target.hostname |
Nilai host.hostname dari pesan JSON dalam. |
host.id |
target.asset.asset_id |
Penggabungan Host Id: dan nilai host.id dari pesan JSON dalam. |
host.ip |
target.asset.ip |
Array alamat IP dari host.ip dalam pesan JSON dalam. |
host.mac |
target.mac |
Array alamat MAC dari host.mac dalam pesan JSON dalam. |
host.os.kernel |
target.platform_patch_level |
Nilai host.os.kernel dari pesan JSON dalam. |
host.os.platform |
target.platform |
Disetel ke LINUX jika host.os.platform adalah debian. |
host.os.version |
target.platform_version |
Nilai host.os.version dari pesan JSON dalam. |
hostname |
principal.hostname |
Nilai hostname yang diekstrak dari kolom message menggunakan grok. |
key |
security_result.detection_fields.value |
Nilai key diekstrak dari kolom message menggunakan grok, dengan key yang sesuai adalah key. |
log.file.path |
principal.process.file.full_path |
Nilai log.file.path dari pesan JSON dalam. |
log_level |
security_result.severity |
Dipetakan berdasarkan nilai log_level: DEBUG, INFO, AUDIT dipetakan ke INFORMATIONAL; ERROR dipetakan ke ERROR; WARNING dipetakan ke MEDIUM. |
log_level |
security_result.severity_details |
Nilai log_level yang diekstrak dari kolom message menggunakan grok. |
log_type |
metadata.log_type |
Nilai log_type dari log mentah. |
message |
security_result.description |
Deskripsi diekstrak dari kolom message menggunakan grok. |
message |
target.process.command_line |
Command line diekstrak dari kolom message menggunakan grok. |
now |
security_result.detection_fields.value |
Nilai now diekstrak dari kolom message menggunakan grok, dengan key yang sesuai adalah now. Diuraikan dari kolom event_time yang diekstrak dari kolom message menggunakan grok. Disetel ke USER_RESOURCE_ACCESS jika hostname dan host.hostname ada, atau disetel ke GENERIC_EVENT. Tetapkan ke CASSANDRA. Tetapkan ke CASSANDRA. Tetapkan ke ephemeral_id. Tetapkan ke VIRTUAL_MACHINE jika cloud.instance.name ada. Setel ke key dan now untuk kolom deteksi yang sesuai. |
timestamp |
timestamp |
Dari kolom create_time log mentah. |
authenticated_var |
event.idm.read_only_udm.principal.user.userid |
Dipetakan dari log perubahan |
authenticated_var |
event.idm.read_only_udm.target.user.userid |
Dipetakan dari log perubahan |
user_var |
event.idm.read_only_udm.target.user.userid |
Dipetakan dari log perubahan |
operation |
event.idm.read_only_udm.security_result.description |
Dipetakan dari log perubahan |
operation |
event.idm.read_only_udm.target.process.command_line |
Dipetakan dari log perubahan |
Log Perubahan
Melihat Log Perubahan untuk parser ini
Perlu bantuan lain? Dapatkan jawaban dari anggota Komunitas dan profesional Google SecOps.