Recoger registros de eventos de Bitwarden Enterprise

Disponible en:

SecOps de Google SIEM

Nota: Esta función está cubierta por los Términos de las Ofertas Previas a la Disponibilidad General de los Términos Específicos del Servicio de Google Security Operations. Las funciones previas a la disponibilidad general pueden tener una asistencia limitada y los cambios que se produzcan en ellas podrían no ser compatibles con otras versiones previas a la disponibilidad general. Para obtener más información, consulta las directrices del servicio de asistencia técnica de Google SecOps y los Términos Específicos de los Servicios de Google SecOps.

En esta guía se explica cómo puede ingerir registros de eventos de Bitwarden Enterprise en Google Security Operations mediante Amazon S3. El analizador transforma los registros de eventos sin procesar en formato JSON en un formato estructurado conforme al modelo de datos unificado de Chronicle. Extrae campos relevantes, como los detalles del usuario, las direcciones IP y los tipos de eventos, y los asigna a los campos de UDM correspondientes para realizar un análisis de seguridad coherente.

Antes de empezar

• Instancia de Google SecOps.
• Acceso privilegiado al arrendatario de Bitwarden.
• Acceso con privilegios a AWS (S3, IAM, Lambda y EventBridge).

Obtener la clave de API y la URL de Bitwarden

1. En la consola de administración de Bitwarden.
2. Ve a Ajustes > Información de la organización > Ver clave de API.
3. Copia y guarda los siguientes detalles en una ubicación segura:
   • ID de cliente
   • Secreto de cliente
4. Determina tus endpoints de Bitwarden (en función de 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)

Configurar un segmento de AWS S3 y IAM para Google SecOps

1. Crea un segmento de Amazon S3 siguiendo esta guía de usuario: Crear un segmento.
2. Guarda el nombre y la región del segmento para consultarlos más adelante (por ejemplo, bitwarden-events).
3. Crea un usuario siguiendo esta guía: Crear un usuario de gestión de identidades y accesos.
4. Selecciona el usuario creado.
5. Selecciona la pestaña Credenciales de seguridad.
6. En la sección Claves de acceso, haz clic en Crear clave de acceso.
7. Selecciona Servicio de terceros en Caso práctico.
8. Haz clic en Siguiente.
9. Opcional: añade 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 futuras consultas.
12. Haz clic en Listo.
13. Selecciona la pestaña Permisos.
14. En la sección Políticas de permisos, haz clic en Añadir permisos.
15. Selecciona Añadir permisos.
16. Seleccione Adjuntar políticas directamente.
17. Busca la política AmazonS3FullAccess.
18. Selecciona la política.
19. Haz clic en Siguiente.
20. Haz clic en Añadir permisos.

Configurar la política y el rol de gestión de identidades y accesos para las subidas de S3

1. Ve a la consola de AWS > IAM > Políticas > Crear política > pestaña JSON.
2. Copia y pega la política que se indica más abajo.
3. JSON de la política (sustituye bitwarden-events si has introducido otro nombre de contenedor):

{
  "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. Adjunte la política que acaba de crear.
4. Dale el nombre WriteBitwardenToS3Role al rol y haz clic en Crear rol.

Crear la función Lambda

1. En la consola de AWS, ve a Lambda > Funciones > Crear función.
2. Haz clic en Crear desde cero.
3. Proporciona los siguientes detalles de configuración:

Ajuste	Valor
Nombre	bitwarden_events_to_s3
Tiempo de ejecución	Python 3.13
Arquitectura	x86_64
Rol de ejecución	WriteBitwardenToS3Role

1. Una vez creada la función, abre la pestaña Código, elimina el stub y pega el código que aparece más abajo (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
    }


 Note: This script is provided as an example and is not officially
supported. We welcome feedback about how we can improve it. To submit
feedback, click Send Feedback > Google SecOps Security Product
Feedback on this page.


if __name__ == "__main__":
    print(lambda_handler())

1. Ve a Configuración > Variables de entorno > Editar > Añadir nueva variable de entorno.
2. Introduce las variables de entorno que se indican a continuación y sustitúyelas 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. Una vez creada la función, permanece en su página (o abre Lambda > Funciones > tu‑función).
2. Seleccione 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.

Nota: El tiempo de espera es un límite superior estricto, lo que significa que, si la función sigue ejecutándose cuando el temporizador llegue a los 5 minutos, AWS Lambda la finalizará. Si la ejecución es más corta, se completará con normalidad y solo se te cobrará por el tiempo de ejecución real.

Crear una programación de EventBridge

1. Ve a Amazon EventBridge > Scheduler > Create schedule (Amazon EventBridge > Programador > Crear programación).
2. Proporcione los siguientes detalles de configuración:
   • Programación periódica: Precio (1 hour).
   • Destino: tu función Lambda.
   • Nombre: bitwarden-events-1h.
3. Haz clic en Crear programación.

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

1. Ve a Consola de AWS > IAM > Usuarios > Añadir usuarios.
2. Haz clic en Add users (Añadir usuarios).
3. Proporcione los siguientes detalles de configuración:
   • Usuario: introduce secops-reader.
   • Tipo de acceso: selecciona Clave de acceso > Acceso programático.
4. Haz clic en Crear usuario.
5. Asigna una política de lectura mínima (personalizada): Usuarios > lector-secops > Permisos > Añadir permisos > Asignar 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 > Añadir 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).

Configurar un feed en Google SecOps para ingerir los registros de eventos de Bitwarden Enterprise

1. Ve a Configuración de SIEM > Feeds.
2. Haz clic en + Añadir nuevo feed.
3. En el campo Nombre del feed, introduce un nombre para el feed (por ejemplo, Bitwarden Events).
4. Selecciona Amazon S3 V2 como Tipo de fuente.
5. Selecciona Eventos de Bitwarden como Tipo de registro.
6. Haz clic en Siguiente.
7. Especifique los valores de los siguientes parámetros de entrada:
   • URI de S3: s3://bitwarden-events/bitwarden/events/
   • Opciones de eliminación de la fuente: selecciona la opción de eliminación que prefieras.
   • Antigüedad máxima de los archivos: 180 días de forma predeterminada.
   • ID de clave de acceso: clave de acceso de usuario con acceso al bucket de S3.
   • Clave de acceso secreta: clave secreta del usuario con acceso al bucket de S3.
   • Espacio de nombres de recursos: el espacio de nombres de recursos.
   • Etiquetas de ingestión: la etiqueta aplicada a los eventos de este feed.
8. Haz clic en Siguiente.
9. Revise la configuración de su nuevo feed en la pantalla Finalizar y, a continuación, haga 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 rellenar el campo target.user.userid.
collectionID	security_result.detection_fields.key	Rellena el campo key de detection_fields en security_result.
collectionID	security_result.detection_fields.value	Rellena el campo value de detection_fields en security_result.
fecha	metadata.event_timestamp	Se ha analizado y convertido a un formato de marca de tiempo y se ha asignado a event_timestamp.
enriched.actingUser.accessAll	security_result.rule_labels.key	Asigna el valor "Access_All" a rule_labels en security_result.
enriched.actingUser.accessAll	security_result.rule_labels.value	Rellena el campo value de rule_labels en security_result con el valor de enriched.actingUser.accessAll convertido en cadena.
enriched.actingUser.email	target.user.email_addresses	Rellena el campo email_addresses de target.user.
enriched.actingUser.id	metadata.product_log_id	Rellena el campo product_log_id de metadata.
enriched.actingUser.id	target.labels.key	Asigna el valor "ID" a target.labels.
enriched.actingUser.id	target.labels.value	Rellena el campo value de target.labels con el valor de enriched.actingUser.id.
enriched.actingUser.name	target.user.user_display_name	Rellena el campo user_display_name de target.user.
enriched.actingUser.object	target.labels.key	Asigna el valor "Object" a target.labels.
enriched.actingUser.object	target.labels.value	Rellena el campo value de target.labels con el valor de enriched.actingUser.object.
enriched.actingUser.resetPasswordEnrolled	target.labels.key	Asigna el valor "ResetPasswordEnrolled" a target.labels.
enriched.actingUser.resetPasswordEnrolled	target.labels.value	Rellena el campo value de target.labels con el valor de enriched.actingUser.resetPasswordEnrolled convertido en cadena.
enriched.actingUser.twoFactorEnabled	security_result.rule_labels.key	Asigna el valor "Two Factor Enabled" a rule_labels en security_result.
enriched.actingUser.twoFactorEnabled	security_result.rule_labels.value	Rellena el campo value de rule_labels en security_result con el valor de enriched.actingUser.twoFactorEnabled convertido en cadena.
enriched.actingUser.userId	target.user.userid	Rellena el campo userid de target.user.
enriched.collection.id	additional.fields.key	Asigna el valor "ID de colección" en additional.fields.
enriched.collection.id	additional.fields.value.string_value	Rellena el campo string_value de additional.fields con el valor de enriched.collection.id.
enriched.collection.object	additional.fields.key	Asigna el valor "Collection Object" a additional.fields.
enriched.collection.object	additional.fields.value.string_value	Rellena el campo string_value de additional.fields con el valor de enriched.collection.object.
enriched.type	metadata.product_event_type	Rellena el campo product_event_type de metadata.
groupId	target.user.group_identifiers	Añade el valor a la matriz group_identifiers de target.user.
ipAddress	principal.ip	Se ha extraído la dirección IP del campo y se ha asignado a principal.ip.
N/A	extensions.auth	El analizador crea un objeto vacío.
N/A	metadata.event_type	Se determina en función de la enriched.type y de la presencia de información sobre principal y target. Valores posibles: USER_LOGIN, STATUS_UPDATE y GENERIC_EVENT.
N/A	security_result.action	Se determina en función de la enriched.type. Valores posibles: ALLOW y BLOCK.
objeto	additional.fields.key	Asigna el valor "Object" a additional.fields.
objeto	additional.fields.value	Rellena el campo value de additional.fields con el valor de object.

¿Necesitas más ayuda? Recibe respuestas de los miembros de la comunidad y de los profesionales de Google SecOps.