收集 Apache Cassandra 記錄
剖析器版本:4.0
本文說明如何使用 Bindplane 代理程式,將 Apache Cassandra 記錄檔擷取至 Google Security Operations。
Apache Cassandra 會產生資料庫作業、叢集事件和系統活動的記錄。剖析器會使用 grok 模式和 JSON 篩選器擷取欄位,然後將這些欄位對應至統合式資料模型 (UDM)。
事前準備
請確認您已完成下列事前準備事項:
- Google SecOps 執行個體
- Windows Server 2016 以上版本,或搭載
systemd的 Linux 主機 - Bindplane 代理程式與 Apache Cassandra 主機之間的網路連線
- 如果透過 Proxy 執行,請確保防火牆通訊埠已根據 Bindplane 代理程式需求開啟
- Apache Cassandra 主機的管理 (SSH) 存取權
取得 Google SecOps 擷取驗證檔案
- 登入 Google SecOps 控制台。
- 依序前往「SIEM 設定」>「收集代理程式」。
- 下載擷取驗證檔案
將檔案安全地儲存在要安裝 Bindplane 代理程式的系統上。
取得 Google SecOps 客戶 ID
- 登入 Google SecOps 控制台。
- 依序前往「SIEM 設定」>「設定檔」。
複製並儲存「機構詳細資料」部分中的客戶 ID。
安裝 Bindplane 代理程式
請按照下列操作說明,在 Windows 或 Linux 作業系統上安裝 Bindplane 代理程式。
Windows 安裝
- 以管理員身分開啟「命令提示字元」或「PowerShell」。
執行下列指令:
msiexec /i "https://github.com/observIQ/bindplane-agent/releases/latest/download/observiq-otel-collector.msi" /quiet等待安裝完成。
執行下列指令,確認安裝成功:
sc query observiq-otel-collector服務應顯示為「RUNNING」。
Linux 安裝
- 開啟具有根層級或 sudo 權限的終端機。
執行下列指令:
sudo sh -c "$(curl -fsSlL https://github.com/observiq/bindplane-agent/releases/latest/download/install_unix.sh)" install_unix.sh等待安裝完成。
執行下列指令,確認安裝成功:
sudo systemctl status observiq-otel-collector服務應顯示為有效 (執行中)。
其他安裝資源
如需其他安裝選項和疑難排解資訊,請參閱 Bindplane 代理程式安裝指南。
設定 Bindplane 代理程式,擷取系統記錄檔並傳送至 Google SecOps
找出設定檔
Linux:
sudo nano /etc/bindplane-agent/config.yamlWindows:
notepad "C:\Program Files\observIQ OpenTelemetry Collector\config.yaml"
編輯設定檔
將
config.yaml的所有內容替換為下列設定: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
設定參數
替換下列預留位置:
接收器設定:
listen_address:要接聽的 IP 位址和通訊埠:0.0.0.0,監聽所有介面 (建議)- 通訊埠
514是標準的系統記錄通訊埠 (在 Linux 上需要根層級權限;非根層級權限請使用1514)
匯出工具設定:
creds_file_path:擷取驗證檔案的完整路徑:- Linux:
/etc/bindplane-agent/ingestion-auth.json - Windows:
C:\Program Files\observIQ OpenTelemetry Collector\ingestion-auth.json
- Linux:
customer_id:從 Google SecOps 控制台複製的客戶 IDendpoint:區域端點網址:- 美國:
malachiteingestion-pa.googleapis.com - 歐洲:
europe-malachiteingestion-pa.googleapis.com - 亞洲:
asia-southeast1-malachiteingestion-pa.googleapis.com - 如需完整清單,請參閱「區域端點」
- 美國:
儲存設定檔
- 編輯完成後,請儲存檔案:
- Linux:依序按下
Ctrl+O、Enter和Ctrl+X - Windows:依序點選「檔案」>「儲存」
- Linux:依序按下
重新啟動 Bindplane 代理程式,以套用變更
如要在 Linux 中重新啟動 Bindplane 代理程式,請執行下列指令:
sudo systemctl restart observiq-otel-collector確認服務正在執行:
```bash sudo systemctl status observiq-otel-collector ```檢查記錄中是否有錯誤:
```bash sudo journalctl -u observiq-otel-collector -f ```
如要在 Windows 中重新啟動 Bindplane 代理程式,請選擇下列其中一個選項:
以管理員身分開啟命令提示字元或 PowerShell:
net stop observiq-otel-collector && net start observiq-otel-collector服務控制台:
- 按下
Win+R,輸入services.msc,然後按下 Enter 鍵。 - 找出 observIQ OpenTelemetry Collector。
- 按一下滑鼠右鍵,然後選取「重新啟動」。
確認服務正在執行:
sc query observiq-otel-collector檢查記錄中是否有錯誤:
type "C:\Program Files\observIQ OpenTelemetry Collector\log\collector.log"
- 按下
在 Apache Cassandra 中設定系統記錄匯出功能
- 使用 SSH 登入 Apache Cassandra 主機。
開啟設定檔
logback.xml:- Apache Cassandra (大多數版本):
$(CASSANDRA_HOME)/conf - Datastax Enterprise (套件安裝):
/etc/dse - Datastax Enterprise (tar 安裝):
$(TARBALL_ROOT)/resources/cassandra/conf
- Apache Cassandra (大多數版本):
在第 28 行的
logback.xml檔案中,加入以下 Appender 定義:<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>請將
BINDPLANE_IP和BINDPLANE_PORT替換為實際的 Bindplane 代理程式 IP 位址和連接埠。在
logback.xml檔案的根記錄器區塊<root level="INFO">中新增下列程式碼:插入這行的位置取決於 Apache Cassandra 版本:
- Apache Cassandra 5.0.x,第 123 行
- Apache Cassandra 4.0.x 和 4.1.x,第 115 行
- Apache Cassandra 3.11.x 和 3.0.x,第 92 行
- Datastax Enterprise (所有版本)、Line 121
<appender-ref ref="SYSLOG" />
UDM 對應表
| 記錄欄位 | UDM 對應 | 邏輯 |
|---|---|---|
agent.ephemeral_id |
observer.labels.value |
內部 JSON 訊息中的 agent.ephemeral_id 值。 |
agent.hostname |
observer.hostname |
內部 JSON 訊息中的 agent.hostname 值。 |
agent.id |
observer.asset_id |
filebeat: 與內部 JSON 訊息中 agent.id 值的串連。 |
agent.name |
observer.user.userid |
內部 JSON 訊息中的 agent.name 值。 |
agent.type |
observer.application |
內部 JSON 訊息中的 agent.type 值。 |
agent.version |
observer.platform_version |
內部 JSON 訊息中的 agent.version 值。 |
cloud.availability_zone |
principal.cloud.availability_zone |
內部 JSON 訊息中的 cloud.availability_zone 值。 |
cloud.instance.id |
principal.resource.product_object_id |
內部 JSON 訊息中的 cloud.instance.id 值。 |
cloud.instance.name |
principal.resource.name |
內部 JSON 訊息中的 cloud.instance.name 值。 |
cloud.machine.type |
principal.resource.attribute.labels.value |
內部 JSON 訊息中的 cloud.machine.type 值,其中對應的 key 為 machine_type。 |
cloud.provider |
principal.resource.attribute.labels.value |
內部 JSON 訊息中的 cloud.provider 值,其中對應的 key 為 provider。 |
event_metadata._id |
metadata.product_log_id |
內部 JSON 訊息中的 event_metadata._id 值。 |
event_metadata.version |
metadata.product_version |
內部 JSON 訊息中的 event_metadata.version 值。 |
host.architecture |
target.asset.hardware.cpu_platform |
內部 JSON 訊息中的 host.architecture 值。 |
host.fqdn |
target.administrative_domain |
內部 JSON 訊息中的 host.fqdn 值。 |
host.hostname |
target.hostname |
內部 JSON 訊息中的 host.hostname 值。 |
host.id |
target.asset.asset_id |
Host Id: 與內部 JSON 訊息中 host.id 值的串連。 |
host.ip |
target.asset.ip |
內部 JSON 訊息中 host.ip 的 IP 位址陣列。 |
host.mac |
target.mac |
來自內部 JSON 訊息的 MAC 位址陣列。host.mac |
host.os.kernel |
target.platform_patch_level |
內部 JSON 訊息中的 host.os.kernel 值。 |
host.os.platform |
target.platform |
如果 host.os.platform 為 debian,請設為 LINUX。 |
host.os.version |
target.platform_version |
內部 JSON 訊息中的 host.os.version 值。 |
hostname |
principal.hostname |
使用 grok 從 message 欄位擷取的 hostname 值。 |
key |
security_result.detection_fields.value |
使用 grok 從 message 欄位擷取的 key 值,其中對應的 key 為 key。 |
log.file.path |
principal.process.file.full_path |
內部 JSON 訊息中的 log.file.path 值。 |
log_level |
security_result.severity |
根據 log_level 的值對應:DEBUG、INFO、AUDIT 對應至 INFORMATIONAL;ERROR 對應至 ERROR;WARNING 對應至 MEDIUM。 |
log_level |
security_result.severity_details |
使用 grok 從 message 欄位擷取的 log_level 值。 |
log_type |
metadata.log_type |
原始記錄中的 log_type 值。 |
message |
security_result.description |
使用 grok 從 message 欄位擷取的說明。 |
message |
target.process.command_line |
使用 grok 從 message 欄位擷取的指令列。 |
now |
security_result.detection_fields.value |
使用 grok 從 message 欄位擷取的 now 值,其中對應的 key 為 now。使用 grok 從 message 欄位擷取的 event_time 欄位中剖析。如果同時存在 hostname 和 host.hostname,請設為 USER_RESOURCE_ACCESS,否則請設為 GENERIC_EVENT。請設為 CASSANDRA。請設為 CASSANDRA。請設為 ephemeral_id。如果 cloud.instance.name 存在,請設為 VIRTUAL_MACHINE。將對應的偵測欄位設為 key 和 now。 |
timestamp |
timestamp |
來自原始記錄的 create_time 欄位。 |
authenticated_var |
event.idm.read_only_udm.principal.user.userid |
從變更記錄對應 |
authenticated_var |
event.idm.read_only_udm.target.user.userid |
從變更記錄對應 |
user_var |
event.idm.read_only_udm.target.user.userid |
從變更記錄對應 |
operation |
event.idm.read_only_udm.security_result.description |
從變更記錄對應 |
operation |
event.idm.read_only_udm.target.process.command_line |
從變更記錄對應 |
變更記錄
還有其他問題嗎?向社群成員和 Google SecOps 專業人員尋求答案。