Collecter les journaux Apache Cassandra

Version de l'analyseur : 4.0

Compatible avec :

Ce document explique comment ingérer des journaux Apache Cassandra dans Google Security Operations à l'aide de l'agent Bindplane.

Apache Cassandra génère des journaux pour les opérations de base de données, les événements de cluster et l'activité du système. L'analyseur extrait les champs à l'aide de modèles grok et de filtres JSON, puis les mappe au modèle de données unifié (UDM).

Avant de commencer

Assurez-vous de remplir les conditions suivantes :

  • Une instance Google SecOps
  • Windows Server 2016 ou version ultérieure, ou hôte Linux avec systemd
  • Connectivité réseau entre l'agent BindPlane et l'hôte Apache Cassandra
  • Si vous exécutez l'agent derrière un proxy, assurez-vous que les ports de pare-feu sont ouverts conformément aux exigences de l'agent BindPlane.
  • Accès administrateur (SSH) à l'hôte Apache Cassandra

Obtenir des identifiants Google SecOps pour l'agent BindPlane

Pour authentifier l'agent Bindplane auprès de Google SecOps, choisissez l'une des méthodes suivantes :

  • Nouveaux déploiements : utilisez l'API Chronicle (option 1).
  • Anciens déploiements : continuez à utiliser le fichier d'authentification d'ingestion (option 2) jusqu'à l'arrêt de l'API Ingestion le 20 juillet 2027.
  1. Connectez-vous à la consoleGoogle Cloud et sélectionnez le projet Google Cloud associé à votre instance Google SecOps.
  2. Accédez à IAM et administration > Comptes de service.
  3. Cliquez sur Créer un compte de service.
  4. Fournissez les informations de configuration suivantes :
    • Nom du compte de service : saisissez un nom pour le compte (par exemple, bindplane-ingest).
    • Description du compte de service : saisissez une description (par exemple, Bindplane agent log ingestion).
  5. Cliquez sur Créer et continuer.
  6. Dans la section Autoriser ce compte de service à accéder au projet, cliquez sur Sélectionner un rôle, puis sélectionnez Éditeur Chronicle.
  7. Cliquez sur Continue (Continuer), puis sur Done (OK).
  8. Cliquez sur le compte de service que vous avez créé, puis accédez à l'onglet Clés.
  9. Cliquez sur Ajouter une clé > Créer une clé.
  10. Sélectionnez JSON, puis cliquez sur Créer. Le fichier de clé est téléchargé sur votre ordinateur.
  11. Enregistrez le fichier de clé sous le nom ingestion-auth.json dans le répertoire du collecteur Bindplane (/opt/observiq-otel-collector/ingestion-auth.json sous Linux ou C:\Program Files\observIQ OpenTelemetry Collector\ingestion-auth.json sous Windows), ou mettez à jour creds_file_path dans config.yaml pour qu'il corresponde au chemin d'accès où vous l'enregistrez.
  12. Accédez à IAM et administration > Paramètres, puis copiez le numéro du projet. Vous en aurez besoin pour configurer l'exportateur.

Option 2 : Télécharger le fichier d'authentification d'ingestion (ancien)

  1. Connectez-vous à la console Google SecOps.
  2. Accédez à Paramètres > Gestion des données > Agents de collecte. Si vous utilisez une plate-forme SIEM uniquement, accédez à Paramètres > Agents de collecte.
  3. Téléchargez le fichier d'authentification d'ingestion.
  4. Enregistrez le fichier de manière sécurisée sur le système où l'agent BindPlane sera installé.

Obtenir le numéro client Google SecOps

  1. Connectez-vous à la console Google SecOps.
  2. Accédez à Paramètres > Administration > Profil. Si vous utilisez une plate-forme SIEM uniquement, accédez à Paramètres > Profil.

  3. Copiez et enregistrez le numéro client de la section Détails de l'organisation.

Installer l'agent BindPlane

Installez l'agent BindPlane sur votre système d'exploitation Windows ou Linux en suivant les instructions ci-dessous.

Installation de Windows

  1. Ouvrez l'invite de commande ou PowerShell en tant qu'administrateur.

  2. Exécutez la commande suivante :

    msiexec /i "https://github.com/observIQ/bindplane-agent/releases/latest/download/observiq-otel-collector.msi" /quiet

  3. Attendez que l'installation se termine.

  4. Vérifiez l'installation en exécutant la commande suivante :

    sc query observiq-otel-collector

    Le service doit s'afficher comme étant EN COURS D'EXÉCUTION.

Installation sous Linux

  1. Ouvrez un terminal avec des droits d'accès racine ou sudo.

  2. Exécutez la commande suivante :

    sudo sh -c "$(curl -fsSlL https://github.com/observiq/bindplane-agent/releases/latest/download/install_unix.sh)" install_unix.sh

  3. Attendez que l'installation se termine.

  4. Vérifiez l'installation en exécutant la commande suivante :

    sudo systemctl status observiq-otel-collector

    Le service doit s'afficher comme actif (en cours d'exécution).

Ressources d'installation supplémentaires

Pour obtenir des options d'installation et de dépannage supplémentaires, consultez le guide d'installation de l'agent Bindplane.

Configurer l'agent Bindplane pour ingérer les journaux Syslog et les envoyer à Google SecOps

Localiser le fichier de configuration

  • Linux :

    sudo nano /opt/observiq-otel-collector/config.yaml

  • Windows :

    notepad "C:\Program Files\observIQ OpenTelemetry Collector\config.yaml"

Modifiez le fichier de configuration

  • Remplacez l'intégralité du contenu de config.yaml par la configuration suivante :

    receivers:
  udplog:
    listen_address: "0.0.0.0:514"

exporters:
  chronicle/cassandra:
    protocol: https
    # Region of your instance, for example us, europe, asia-southeast1
    location: <LOCATION>
    # Project number of the Google Cloud project linked to the instance
    project: '<PROJECT_NUMBER>'
    compression: gzip
    creds_file_path: '/opt/observiq-otel-collector/ingestion-auth.json'
    customer_id: '<customer_id>'
    endpoint: chronicle.googleapis.com
    log_type: CASSANDRA
    raw_log_field: body

service:
  pipelines:
    logs/cassandra_to_chronicle:
      receivers:
        - udplog
      exporters:
        - chronicle/cassandra

Paramètres de configuration

Remplacez les espaces réservés suivants :

  • Configuration du récepteur :

    • listen_address : adresse IP et port d'écoute :
      • 0.0.0.0 pour écouter sur toutes les interfaces (recommandé)
      • Le port 514 est le port syslog standard (nécessite un accès racine sous Linux ; utilisez 1514 pour un accès non racine).

  • Configuration de l'exportateur :

    • creds_file_path : chemin d'accès complet au fichier de clé JSON du compte de service (option 1) :
      • Linux : /opt/observiq-otel-collector/ingestion-auth.json
      • Windows : C:\Program Files\observIQ OpenTelemetry Collector\ingestion-auth.json
    • customer_id : ID client copié depuis la console Google SecOps
    • location : remplacez <LOCATION> par la région de votre instance Google SecOps (par exemple, us, europe ou asia-southeast1). L'exportateur ajoute cette valeur en préfixe à chronicle.googleapis.com. Pour obtenir la liste complète, consultez Points de terminaison régionaux.
    • project : remplacez <PROJECT_NUMBER> par le numéro de projet indiqué dans IAM et administration > Paramètres.
    • endpoint : laissez la valeur définie sur chronicle.googleapis.com.

Ancien exportateur d'API d'ingestion

  • Si vous utilisez le fichier d'authentification d'ingestion de l'option 2, remplacez le bloc exporters par le code suivant. Définissez creds_file_path sur le chemin d'accès au fichier d'authentification d'ingestion. Si votre instance se trouve en dehors des États-Unis, remplacez malachiteingestion-pa.googleapis.com par votre point de terminaison régional (par exemple, europe-malachiteingestion-pa.googleapis.com).

    exporters:
  chronicle/cassandra:
    compression: gzip
    creds_file_path: '/opt/observiq-otel-collector/ingestion-auth.json'
    customer_id: '<customer_id>'
    endpoint: malachiteingestion-pa.googleapis.com
    log_type: CASSANDRA
    raw_log_field: body

Enregistrez le fichier de configuration.

  • Après avoir modifié le fichier, enregistrez-le :
    • Linux : appuyez sur Ctrl+O, puis sur Enter, puis sur Ctrl+X.
    • Windows : cliquez sur Fichier > Enregistrer.

Redémarrez l'agent BindPlane pour appliquer les modifications.

  • Pour redémarrer l'agent BindPlane sous Linux, exécutez la commande suivante :

    sudo systemctl restart observiq-otel-collector

    1. Vérifiez que le service est en cours d'exécution :

      ```bash
sudo systemctl status observiq-otel-collector
```

    2. Vérifiez les journaux pour détecter d'éventuelles erreurs :

      ```bash
sudo journalctl -u observiq-otel-collector -f
```

  • Pour redémarrer l'agent BindPlane sous Windows, choisissez l'une des options suivantes :

    • Invite de commande ou PowerShell en tant qu'administrateur :

      net stop observiq-otel-collector && net start observiq-otel-collector

    • Console Services :

      1. Appuyez sur Win+R, saisissez services.msc, puis appuyez sur Entrée.
      2. Recherchez observIQ OpenTelemetry Collector.
      3. Effectuez un clic droit et sélectionnez Redémarrer.

      4. Vérifiez que le service est en cours d'exécution :

        sc query observiq-otel-collector

      5. Vérifiez les journaux pour détecter d'éventuelles erreurs :

        type "C:\Program Files\observIQ OpenTelemetry Collector\log\collector.log"

Configurer l'exportation syslog dans Apache Cassandra

  1. Connectez-vous à l'hôte Apache Cassandra via SSH.

  2. Ouvrez le fichier de configuration logback.xml :

    • Apache Cassandra (la plupart des versions) : $(CASSANDRA_HOME)/conf
    • Datastax Enterprise (installation du package) : /etc/dse
    • Datastax Enterprise (installation tar) : $(TARBALL_ROOT)/resources/cassandra/conf

  3. Ajoutez la définition Appender suivante au fichier logback.xml à la ligne 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>

  4. Remplacez BINDPLANE_IP et BINDPLANE_PORT par l'adresse IP et le port réels de l'agent Bindplane.

  5. Ajoutez le code suivant au bloc de l'enregistreur racine <root level="INFO"> dans le fichier logback.xml :

    L'emplacement où cette ligne est insérée dépend de votre version d'Apache Cassandra :

    • Apache Cassandra 5.0.x, ligne 123
    • Apache Cassandra 4.0.x et 4.1.x, ligne 115
    • Apache Cassandra 3.11.x et 3.0.x, ligne 92
    • Datastax Enterprise (toutes les versions), ligne 121
    <appender-ref ref="SYSLOG" />

Table de mappage UDM

Champ du journal Mappage UDM Logique
agent.ephemeral_id observer.labels.value Valeur de agent.ephemeral_id du message JSON interne.
agent.hostname observer.hostname Valeur de agent.hostname du message JSON interne.
agent.id observer.asset_id Concaténation de filebeat: et de la valeur de agent.id du message JSON interne.
agent.name observer.user.userid Valeur de agent.name du message JSON interne.
agent.type observer.application Valeur de agent.type du message JSON interne.
agent.version observer.platform_version Valeur de agent.version du message JSON interne.
cloud.availability_zone principal.cloud.availability_zone Valeur de cloud.availability_zone du message JSON interne.
cloud.instance.id principal.resource.product_object_id Valeur de cloud.instance.id du message JSON interne.
cloud.instance.name principal.resource.name Valeur de cloud.instance.name du message JSON interne.
cloud.machine.type principal.resource.attribute.labels.value Valeur de cloud.machine.type du message JSON interne, où la valeur key correspondante est machine_type.
cloud.provider principal.resource.attribute.labels.value Valeur de cloud.provider du message JSON interne, où la valeur key correspondante est provider.
event_metadata._id metadata.product_log_id Valeur de event_metadata._id du message JSON interne.
event_metadata.version metadata.product_version Valeur de event_metadata.version du message JSON interne.
host.architecture target.asset.hardware.cpu_platform Valeur de host.architecture du message JSON interne.
host.fqdn target.administrative_domain Valeur de host.fqdn du message JSON interne.
host.hostname target.hostname Valeur de host.hostname du message JSON interne.
host.id target.asset.asset_id Concaténation de Host Id: et de la valeur de host.id du message JSON interne.
host.ip target.asset.ip Tableau d'adresses IP de host.ip dans le message JSON interne.
host.mac target.mac Tableau d'adresses MAC de host.mac dans le message JSON interne.
host.os.kernel target.platform_patch_level Valeur de host.os.kernel du message JSON interne.
host.os.platform target.platform Définie sur LINUX, si host.os.platform est debian.
host.os.version target.platform_version Valeur de host.os.version du message JSON interne.
hostname principal.hostname Valeur de hostname extraite du champ message à l'aide de grok.
key security_result.detection_fields.value Valeur de key extraite du champ message à l'aide de grok, où le key correspondant est key.
log.file.path principal.process.file.full_path Valeur de log.file.path du message JSON interne.
log_level security_result.severity Mappé en fonction de la valeur de log_level : DEBUG, INFO, AUDIT sont mappés sur INFORMATIONAL ; ERROR est mappé sur ERROR ; WARNING est mappé sur MEDIUM.
log_level security_result.severity_details Valeur de log_level extraite du champ message à l'aide de grok.
log_type metadata.log_type Valeur de log_type du journal brut.
message security_result.description Description extraite du champ message à l'aide de grok.
message target.process.command_line Ligne de commande extraite du champ message à l'aide de grok.
now security_result.detection_fields.value Valeur de now extraite du champ message à l'aide de grok, où le key correspondant est now. Analysé à partir du champ event_time extrait du champ message à l'aide de grok. Définie sur USER_RESOURCE_ACCESS si hostname et host.hostname sont présents, sinon sur GENERIC_EVENT. Définissez cet élément sur CASSANDRA. Définissez cet élément sur CASSANDRA. Définissez cet élément sur ephemeral_id. Définie sur VIRTUAL_MACHINE si cloud.instance.name est présent. Définissez sur key et now pour les champs de détection correspondants.
timestamp timestamp Du champ create_time du journal brut.
authenticated_var event.idm.read_only_udm.principal.user.userid Mappé à partir du journal des modifications
authenticated_var event.idm.read_only_udm.target.user.userid Mappé à partir du journal des modifications
user_var event.idm.read_only_udm.target.user.userid Mappé à partir du journal des modifications
operation event.idm.read_only_udm.security_result.description Mappé à partir du journal des modifications
operation event.idm.read_only_udm.target.process.command_line Mappé à partir du journal des modifications

Journal des modifications

Afficher le journal des modifications de cet analyseur

Vous avez encore besoin d'aide ? Obtenez des réponses de membres de la communauté et de professionnels Google SecOps.