Recopila registros de Apache Cassandra

Compatible con:

En este documento, se explica cómo transferir registros de Apache Cassandra a Google Security Operations con Bindplane. El analizador extrae campos y los convierte en el modelo de datos unificado (UDM). Utiliza patrones de Grok para analizar el mensaje inicial, luego usa un filtro JSON para los datos anidados y realiza transformaciones condicionales para asignar varios campos a sus equivalentes en el UDM, controlando diferentes niveles de registro y enriqueciendo el resultado con metadatos.

Antes de comenzar

Asegúrate de cumplir con los siguientes requisitos previos:

  • Instancia de Google SecOps
  • Host de Windows 2016 o posterior, o de Linux con systemd
  • Si se ejecuta detrás de un proxy, los puertos de firewall están abiertos.
  • Acceso con privilegios a una instancia de Apache Cassandra

Obtén el archivo de autenticación de transferencia de Google SecOps

  1. Accede a la consola de Google SecOps.
  2. Ve a SIEM Settings > Collection Agents.
  3. Descarga el archivo de autenticación de transferencia. Guarda el archivo de forma segura en el sistema en el que se instalará BindPlane.

Obtén el ID de cliente de Google SecOps

  1. Accede a la consola de Google SecOps.
  2. Ve a SIEM Settings > Profile.
  3. Copia y guarda el ID de cliente de la sección Detalles de la organización.

Instala el agente de BindPlane

Instalación en Windows

  1. Abre el símbolo del sistema o PowerShell como administrador.
  2. Ejecuta el siguiente comando:

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

Instalación en Linux

  1. Abre una terminal con privilegios de raíz o sudo.
  2. Ejecuta el siguiente comando:

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

Recursos de instalación adicionales

Para obtener más opciones de instalación, consulta la guía de instalación.

Configura el agente de BindPlane para transferir Syslog y enviarlo a Google SecOps

  1. Accede al archivo de configuración:
    • Ubica el archivo config.yaml. Por lo general, se encuentra en el directorio /etc/bindplane-agent/ en Linux o en el directorio de instalación en Windows.
    • Abre el archivo con un editor de texto (por ejemplo, nano, vi o Bloc de notas).
  2. Edita el archivo config.yaml de la siguiente manera:

    receivers:
        udplog:
            # Replace the port and IP address as required
            listen_address: `0.0.0.0:514`
    
    exporters:
        chronicle/chronicle_w_labels:
            compression: gzip
            # Adjust the path to the credentials file you downloaded in Step 1
            creds: '/path/to/ingestion-authentication-file.json'
            # Replace with your actual customer ID from Step 2
            customer_id: <customer_id>
            endpoint: malachiteingestion-pa.googleapis.com
            # Add optional ingestion labels for better organization
            ingestion_labels:
                log_type: 'CASSANDRA'
                raw_log_field: body
    
    service:
        pipelines:
            logs/source0__chronicle_w_labels-0:
                receivers:
                    - udplog
                exporters:
                    - chronicle/chronicle_w_labels
    
  3. Reemplaza el puerto y la dirección IP según sea necesario en tu infraestructura.

  4. Reemplaza <customer_id> por el ID de cliente real.

  5. Actualiza /path/to/ingestion-authentication-file.json a la ruta de acceso en la que se guardó el archivo de autenticación en la sección Cómo obtener el archivo de autenticación de la transferencia de Google SecOps.

Reinicia el agente de Bindplane para aplicar los cambios

  • Para reiniciar el agente de Bindplane en Linux, ejecuta el siguiente comando:

    sudo systemctl restart bindplane-agent
    
  • Para reiniciar el agente de Bindplane en Windows, puedes usar la consola de Servicios o ingresar el siguiente comando:

    net stop BindPlaneAgent && net start BindPlaneAgent
    

Configura la exportación de Syslog en Apache Cassandra

  1. Accede al host de Apache Cassandra con SSH.
  2. Abre el archivo de configuración logback.xml e inserta el siguiente código en la línea 28:
    • En la mayoría de las versiones de Apache Cassandra, la ubicación sería $(CASSANDRA_HOME)/conf.
    • En las instalaciones de paquetes de Datastax Enterprise, la ubicación sería /etc/dse.
    • En las instalaciones de archivos tar de DSE, la ubicación sería $(TARBALL_ROOT)/resources/cassandra/conf.
  3. Agrega la siguiente definición de Appender al archivo logback.xml en la línea 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. Reemplaza bindplane-ip y bindplane-port por la dirección IP y el puerto reales del agente de Bindplane.

  5. Agrega el siguiente código al bloque del registrador raíz <root level=INFO> en el archivo logback.xml:

    1. La ubicación en la que se inserta esta línea depende de tu versión de Apache Cassandra:

      • Apache Cassandra 5.0.x, línea 123.
      • Apache Cassandra 4.0.x y 4.1.x, línea 115.
      • Apache Cassandra 3.11.x y 3.0.x, línea 92.
      • Datastax Enterprise (todas las versiones), línea 121.
      <appender-ref ref=`SYSLOG` />
      

Tabla de asignación de UDM

Campo de registro Asignación de UDM Lógica
agent.ephemeral_id observer.labels.value Valor de agent.ephemeral_id del mensaje JSON interno.
agent.hostname observer.hostname Valor de agent.hostname del mensaje JSON interno.
agent.id observer.asset_id Es la concatenación de filebeat: y el valor de agent.id del mensaje JSON interno.
agent.name observer.user.userid Valor de agent.name del mensaje JSON interno.
agent.type observer.application Valor de agent.type del mensaje JSON interno.
agent.version observer.platform_version Valor de agent.version del mensaje JSON interno.
cloud.availability_zone principal.cloud.availability_zone Valor de cloud.availability_zone del mensaje JSON interno.
cloud.instance.id principal.resource.product_object_id Valor de cloud.instance.id del mensaje JSON interno.
cloud.instance.name principal.resource.name Valor de cloud.instance.name del mensaje JSON interno.
cloud.machine.type principal.resource.attribute.labels.value Valor de cloud.machine.type del mensaje JSON interno, en el que el key correspondiente es machine_type.
cloud.provider principal.resource.attribute.labels.value Valor de cloud.provider del mensaje JSON interno, en el que el key correspondiente es provider.
event_metadata._id metadata.product_log_id Valor de event_metadata._id del mensaje JSON interno.
event_metadata.version metadata.product_version Valor de event_metadata.version del mensaje JSON interno.
host.architecture target.asset.hardware.cpu_platform Valor de host.architecture del mensaje JSON interno.
host.fqdn target.administrative_domain Valor de host.fqdn del mensaje JSON interno.
host.hostname target.hostname Valor de host.hostname del mensaje JSON interno.
host.id target.asset.asset_id Es la concatenación de Host Id: y el valor de host.id del mensaje JSON interno.
host.ip target.asset.ip Es un array de direcciones IP de host.ip en el mensaje JSON interno.
host.mac target.mac Es un array de direcciones MAC de host.mac en el mensaje JSON interno.
host.os.kernel target.platform_patch_level Valor de host.os.kernel del mensaje JSON interno.
host.os.platform target.platform Se establece en LINUX, si host.os.platform es debian.
host.os.version target.platform_version Valor de host.os.version del mensaje JSON interno.
hostname principal.hostname Valor de hostname extraído del campo message con Grok.
key security_result.detection_fields.value Valor de key extraído del campo message con Grok, en el que el key correspondiente es key.
log.file.path principal.process.file.full_path Valor de log.file.path del mensaje JSON interno.
log_level security_result.severity Se asigna según el valor de log_level: DEBUG, INFO y AUDIT se asignan a INFORMATIONAL; ERROR se asigna a ERROR; WARNING se asigna a MEDIUM.
log_level security_result.severity_details Valor de log_level extraído del campo message con Grok.
log_type metadata.log_type Valor de log_type del registro sin procesar.
message security_result.description Es la descripción extraída del campo message con grok.
message target.process.command_line Línea de comandos extraída del campo message con grok.
now security_result.detection_fields.value Valor de now extraído del campo message con Grok, en el que el key correspondiente es now. Se analizó a partir del campo event_time extraído del campo message con Grok. Se establece en USER_RESOURCE_ACCESS si están presentes hostname y host.hostname; de lo contrario, se establece en GENERIC_EVENT. Se establece en CASSANDRA. Se establece en CASSANDRA. Se establece en ephemeral_id. Se establece en VIRTUAL_MACHINE si cloud.instance.name está presente. Se establece en key y now para los campos de detección correspondientes.
timestamp timestamp Del campo create_time del registro sin procesar.

¿Necesitas más ayuda? Obtén respuestas de miembros de la comunidad y profesionales de Google SecOps.