Recopila registros de eventos de Bitwarden Enterprise

Se admite en los siguientes sistemas operativos:

En esta guía, se explica cómo puedes transferir registros de eventos de Bitwarden Enterprise a Google Security Operations con Amazon S3. El analizador transforma los registros de eventos sin procesar con formato JSON en un formato estructurado que cumple con el UDM de Chronicle. Extrae campos relevantes, como detalles del usuario, direcciones IP y tipos de eventos, y los asigna a los campos correspondientes del UDM para realizar un análisis de seguridad coherente.

Antes de comenzar

  • Es la instancia de Google SecOps.
  • Acceso con privilegios al arrendatario de Bitwarden
  • Acceso con privilegios a AWS (S3, IAM, Lambda, EventBridge)

Obtén la URL y la clave de API de Bitwarden

  1. En la Consola del administrador de Bitwarden
  2. Ve a Configuración > Información de la organización > Ver clave de API.
  3. Copia y guarda los siguientes detalles en una ubicación segura:
    • Client ID (ID de cliente)
    • Client Secret (Secreto del cliente)
  4. Determina tus extremos de Bitwarden (según la región):
    • IDENTITY_URL = https://identity.bitwarden.com/connect/token (UE: https://identity.bitwarden.eu/connect/token)
    • API_BASE = https://api.bitwarden.com (UE: https://api.bitwarden.eu)

Configura el bucket de AWS S3 y el IAM para Google SecOps

  1. Crea un bucket de Amazon S3 siguiendo esta guía del usuario: Crea un bucket
  2. Guarda el Nombre y la Región del bucket para futuras referencias (por ejemplo, bitwarden-events).
  3. Crea un usuario siguiendo esta guía del usuario: Cómo crear un usuario de IAM.
  4. Selecciona el usuario creado.
  5. Selecciona la pestaña Credenciales de seguridad.
  6. Haz clic en Crear clave de acceso en la sección Claves de acceso.
  7. Selecciona Servicio de terceros como Caso de uso.
  8. Haz clic en Siguiente.
  9. Opcional: Agrega una etiqueta de descripción.
  10. Haz clic en Crear clave de acceso.
  11. Haz clic en Descargar archivo .csv para guardar la clave de acceso y la clave de acceso secreta para consultarlas en el futuro.
  12. Haz clic en Listo.
  13. Selecciona la pestaña Permisos.
  14. Haz clic en Agregar permisos en la sección Políticas de permisos.
  15. Selecciona Agregar permisos.
  16. Selecciona Adjuntar políticas directamente.
  17. Busca la política AmazonS3FullAccess.
  18. Selecciona la política.
  19. Haz clic en Siguiente.
  20. Haz clic en Agregar permisos.

Configura la política y el rol de IAM para las cargas de S3

  1. Ve a la consola de AWS > IAM > Políticas > Crear política > pestaña JSON.
  2. Copia y pega la siguiente política.
  3. JSON de la política (reemplaza bitwarden-events si ingresaste un nombre de bucket diferente):
{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "AllowPutBitwardenObjects",
      "Effect": "Allow",
      "Action": "s3:PutObject",
      "Resource": "arn:aws:s3:::bitwarden-events/*"
    },
    {
      "Sid": "AllowGetStateObject",
      "Effect": "Allow",
      "Action": "s3:GetObject",
      "Resource": "arn:aws:s3:::bitwarden-events/bitwarden/events/state.json"
    }
  ]
}

  1. Haz clic en Siguiente > Crear política.
  2. Ve a IAM > Roles > Crear rol > Servicio de AWS > Lambda.
  3. Adjunta la política recién creada.
  4. Nombra el rol WriteBitwardenToS3Role y haz clic en Crear rol.

Crea la función Lambda

  1. En la consola de AWS, ve a Lambda > Functions > Create function.
  2. Haz clic en Crear desde cero.
  3. Proporciona los siguientes detalles de configuración:
Configuración Valor
Nombre bitwarden_events_to_s3
Tiempo de ejecución Python 3.13
Arquitectura x86_64
Rol de ejecución WriteBitwardenToS3Role
  1. Después de crear la función, abre la pestaña Code, borra el código auxiliar y pega el siguiente código (bitwarden_events_to_s3.py).
#!/usr/bin/env python3

import os, json, time, urllib.parse
from urllib.request import Request, urlopen
from urllib.error import HTTPError, URLError
import boto3

IDENTITY_URL = os.environ.get("IDENTITY_URL", "https://identity.bitwarden.com/connect/token")
API_BASE = os.environ.get("API_BASE", "https://api.bitwarden.com").rstrip("/")
CID = os.environ["BW_CLIENT_ID"]          # organization.ClientId
CSECRET = os.environ["BW_CLIENT_SECRET"]  # organization.ClientSecret
BUCKET = os.environ["S3_BUCKET"]
PREFIX = os.environ.get("S3_PREFIX", "bitwarden/events/").strip("/")
STATE_KEY = os.environ.get("STATE_KEY", "bitwarden/events/state.json")
MAX_PAGES = int(os.environ.get("MAX_PAGES", "10"))

HEADERS_FORM = {"Content-Type": "application/x-www-form-urlencoded"}
HEADERS_JSON = {"Accept": "application/json"}

s3 = boto3.client("s3")


def _read_state():
    try:
        obj = s3.get_object(Bucket=BUCKET, Key=STATE_KEY)
        j = json.loads(obj["Body"].read())
        return j.get("continuationToken")
    except Exception:
        return None


def _write_state(token):
    body = json.dumps({"continuationToken": token}).encode("utf-8")
    s3.put_object(Bucket=BUCKET, Key=STATE_KEY, Body=body, ContentType="application/json")


def _http(req: Request, timeout: int = 60, max_retries: int = 5):
    attempt, backoff = 0, 1.0
    while True:
        try:
            with urlopen(req, timeout=timeout) as r:
                return json.loads(r.read().decode("utf-8"))
        except HTTPError as e:
            # Retry on 429 and 5xx
            if (e.code == 429 or 500 <= e.code <= 599) and attempt < max_retries:
                time.sleep(backoff); attempt += 1; backoff *= 2; continue
            raise
        except URLError:
            if attempt < max_retries:
                time.sleep(backoff); attempt += 1; backoff *= 2; continue
            raise


def _get_token():
    body = urllib.parse.urlencode({
        "grant_type": "client_credentials",
        "scope": "api.organization",
        "client_id": CID,
        "client_secret": CSECRET,
    }).encode("utf-8")
    req = Request(IDENTITY_URL, data=body, method="POST", headers=HEADERS_FORM)
    data = _http(req, timeout=30)
    return data["access_token"], int(data.get("expires_in", 3600))


def _fetch_events(bearer: str, cont: str | None):
    params = {}
    if cont:
        params["continuationToken"] = cont
    qs = ("?" + urllib.parse.urlencode(params)) if params else ""
    url = f"{API_BASE}/public/events{qs}"
    req = Request(url, method="GET", headers={"Authorization": f"Bearer {bearer}", **HEADERS_JSON})
    return _http(req, timeout=60)


def _write_events_jsonl(events: list, run_ts_s: int, page_index: int) -> str:
    """
    Write events in JSONL format (one JSON object per line).
    Only writes if there are events to write.
    Returns the S3 key of the written file.
    """
    if not events:
        return None
    
    # Build JSONL content: one event per line
    lines = [json.dumps(event, separators=(",", ":")) for event in events]
    jsonl_content = "\n".join(lines) + "\n"  # JSONL format with trailing newline
    
    # Generate unique filename with page number to avoid conflicts
    key = f"{PREFIX}/{time.strftime('%Y/%m/%d/%H%M%S', time.gmtime(run_ts_s))}-page{page_index:05d}-bitwarden-events.jsonl"
    
    s3.put_object(
        Bucket=BUCKET,
        Key=key,
        Body=jsonl_content.encode("utf-8"),
        ContentType="application/x-ndjson",  # MIME type for JSONL
    )
    return key


def lambda_handler(event=None, context=None):
    bearer, _ttl = _get_token()
    cont = _read_state()
    run_ts_s = int(time.time())

    pages = 0
    total_events = 0
    written_files = []
    
    while pages < MAX_PAGES:
        data = _fetch_events(bearer, cont)
        
        # Extract events array from API response
        # API returns: {"object":"list", "data":[...], "continuationToken":"..."}
        events = data.get("data", [])
        
        # Only write file if there are events
        if events:
            s3_key = _write_events_jsonl(events, run_ts_s, pages)
            if s3_key:
                written_files.append(s3_key)
                total_events += len(events)
        
        pages += 1
        
        # Check for next page token
        next_cont = data.get("continuationToken")
        if next_cont:
            cont = next_cont
            continue
        else:
            # No more pages
            break
    
    # Save state only if there are more pages to continue in next run
    # If we hit MAX_PAGES and there's still a continuation token, save it
    # Otherwise, clear the state (set to None)
    _write_state(cont if pages >= MAX_PAGES and cont else None)
    
    return {
        "ok": True,
        "pages": pages,
        "total_events": total_events,
        "files_written": len(written_files),
        "nextContinuationToken": cont if pages >= MAX_PAGES else None
    }




if __name__ == "__main__":
    print(lambda_handler())
  1. Ve a Configuración > Variables de entorno > Editar > Agregar nueva variable de entorno.
  2. Ingresa las variables de entorno que se proporcionan a continuación y reemplaza los marcadores de posición por tus valores.

Variables de entorno

Clave Ejemplo
S3_BUCKET bitwarden-events
S3_PREFIX bitwarden/events/
STATE_KEY bitwarden/events/state.json
BW_CLIENT_ID <organization client_id>
BW_CLIENT_SECRET <organization client_secret>
IDENTITY_URL https://identity.bitwarden.com/connect/token (UE: https://identity.bitwarden.eu/connect/token)
API_BASE https://api.bitwarden.com (UE: https://api.bitwarden.eu)
MAX_PAGES 10
  1. Después de crear la función, permanece en su página (o abre Lambda > Functions > your‑function).
  2. Selecciona la pestaña Configuración.
  3. En el panel Configuración general, haz clic en Editar.
  4. Cambia Tiempo de espera a 5 minutos (300 segundos) y haz clic en Guardar.

Crea una programación de EventBridge

  1. Ve a Amazon EventBridge > Scheduler > Create schedule.
  2. Proporciona los siguientes detalles de configuración:
    • Programación recurrente: Frecuencia (1 hour).
    • Objetivo: Tu función de Lambda.
    • Nombre: bitwarden-events-1h.
  3. Haz clic en Crear programación.

(Opcional) Crea un usuario y claves de IAM de solo lectura para Google SecOps

  1. Ve a Consola de AWS > IAM > Usuarios > Agregar usuarios.
  2. Haz clic en Agregar usuarios.
  3. Proporciona los siguientes detalles de configuración:
    • Usuario: Ingresa secops-reader.
    • Tipo de acceso: Selecciona Clave de acceso: Acceso programático.
  4. Haz clic en Crear usuario.
  5. Adjunta una política de lectura mínima (personalizada): Usuarios > secops-reader > Permisos > Agregar permisos > Adjuntar políticas directamente > Crear política.
  6. JSON:
{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": ["s3:GetObject"],
      "Resource": "arn:aws:s3:::<your-bucket>/*"
    },
    {
      "Effect": "Allow",
      "Action": ["s3:ListBucket"],
      "Resource": "arn:aws:s3:::<your-bucket>"
    }
  ]
}
  1. Nombre = secops-reader-policy.
  2. Haz clic en Crear política > busca o selecciona > Siguiente > Agregar permisos.
  3. Crea una clave de acceso para secops-reader: Credenciales de seguridad > Claves de acceso > Crear clave de acceso > descarga el archivo .csv (pegarás estos valores en el feed).

Configura un feed en Google SecOps para transferir los registros de eventos de Bitwarden Enterprise

  1. Ve a Configuración de SIEM > Feeds.
  2. Haz clic en + Agregar feed nuevo.
  3. En el campo Nombre del feed, ingresa un nombre para el feed (por ejemplo, Bitwarden Events).
  4. Selecciona Amazon S3 V2 como el Tipo de fuente.
  5. Selecciona Eventos de Bitwarden como el Tipo de registro.
  6. Haz clic en Siguiente.
  7. Especifica valores para los siguientes parámetros de entrada:
    • URI de S3: s3://bitwarden-events/bitwarden/events/
    • Opciones de borrado de la fuente: Selecciona la opción de borrado según tu preferencia.
    • Antigüedad máxima del archivo: 180 días de forma predeterminada
    • ID de clave de acceso: Clave de acceso del usuario con acceso al bucket de S3.
    • Clave de acceso secreta: Clave secreta del usuario con acceso al bucket de S3.
    • Espacio de nombres del recurso: Es el espacio de nombres del recurso.
    • Etiquetas de transmisión: Es la etiqueta que se aplica a los eventos de este feed.
  8. Haz clic en Siguiente.
  9. Revisa la nueva configuración del feed en la pantalla Finalizar y, luego, haz clic en Enviar.

Tabla de asignación de UDM

Campo de registro Asignación de UDM Lógica
actingUserId target.user.userid Si enriched.actingUser.userId está vacío o es nulo, este campo se usa para propagar el campo target.user.userid.
collectionID security_result.detection_fields.key Propaga el campo key dentro de detection_fields en security_result.
collectionID security_result.detection_fields.value Propaga el campo value dentro de detection_fields en security_result.
fecha metadata.event_timestamp Se analizó y convirtió a un formato de marca de tiempo, y se asignó a event_timestamp.
enriched.actingUser.accessAll security_result.rule_labels.key Establece el valor en "Access_All" dentro de rule_labels en security_result.
enriched.actingUser.accessAll security_result.rule_labels.value Propaga el campo value dentro de rule_labels en security_result con el valor de enriched.actingUser.accessAll convertido en cadena.
enriched.actingUser.email target.user.email_addresses Propaga el campo email_addresses dentro de target.user.
enriched.actingUser.id metadata.product_log_id Propaga el campo product_log_id dentro de metadata.
enriched.actingUser.id target.labels.key Establece el valor en "ID" dentro de target.labels.
enriched.actingUser.id target.labels.value Propaga el campo value dentro de target.labels con el valor de enriched.actingUser.id.
enriched.actingUser.name target.user.user_display_name Propaga el campo user_display_name dentro de target.user.
enriched.actingUser.object target.labels.key Establece el valor en "Object" dentro de target.labels.
enriched.actingUser.object target.labels.value Propaga el campo value dentro de target.labels con el valor de enriched.actingUser.object.
enriched.actingUser.resetPasswordEnrolled target.labels.key Establece el valor en "ResetPasswordEnrolled" dentro de target.labels.
enriched.actingUser.resetPasswordEnrolled target.labels.value Propaga el campo value dentro de target.labels con el valor de enriched.actingUser.resetPasswordEnrolled convertido en cadena.
enriched.actingUser.twoFactorEnabled security_result.rule_labels.key Establece el valor en "Two Factor Enabled" dentro de rule_labels en security_result.
enriched.actingUser.twoFactorEnabled security_result.rule_labels.value Propaga el campo value dentro de rule_labels en security_result con el valor de enriched.actingUser.twoFactorEnabled convertido en cadena.
enriched.actingUser.userId target.user.userid Propaga el campo userid dentro de target.user.
enriched.collection.id additional.fields.key Establece el valor en "ID de colección" dentro de additional.fields.
enriched.collection.id additional.fields.value.string_value Propaga el campo string_value dentro de additional.fields con el valor de enriched.collection.id.
enriched.collection.object additional.fields.key Establece el valor en "Objeto de colección" dentro de additional.fields.
enriched.collection.object additional.fields.value.string_value Propaga el campo string_value dentro de additional.fields con el valor de enriched.collection.object.
enriched.type metadata.product_event_type Propaga el campo product_event_type dentro de metadata.
groupId target.user.group_identifiers Agrega el valor al array group_identifiers dentro de target.user.
ipAddress principal.ip Se extrajo la dirección IP del campo y se asignó a principal.ip.
N/A extensions.auth El analizador crea un objeto vacío.
N/A metadata.event_type Se determina según el enriched.type y la presencia de información de principal y target. Los valores posibles son USER_LOGIN, STATUS_UPDATE y GENERIC_EVENT.
N/A security_result.action Se determina en función de enriched.type. Valores posibles: ALLOW, BLOCK.
objeto additional.fields.key Establece el valor en "Object" dentro de additional.fields.
objeto additional.fields.value Propaga el campo value dentro de additional.fields con el valor de object.

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