Recopila registros de eventos de Bitwarden Enterprise

En este documento, se explica cómo 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 se ajusta al 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

• 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 el 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 usarlas más adelante.
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 y selecciona la política AmazonS3FullAccess.
18. Haz clic en Siguiente.
19. 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. Ingresa la siguiente política:

   {
     "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"
       }
     ]
   }
   
   

   • Reemplaza bitwarden-events si ingresaste un nombre de bucket diferente.

3. Haz clic en Siguiente > Crear política.

4. Ve a IAM > Roles > Crear rol > Servicio de AWS > Lambda.

5. Adjunta la política recién creada.

6. Asigna el nombre WriteBitwardenToS3Role al rol 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

4. Después de crear la función, abre la pestaña Code, borra el código auxiliar y, luego, ingresa 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_page(obj: dict, run_ts_s: int, page_index: int) -> str:
       # Make filename unique per page to avoid overwrites in the same second
       key = f"{PREFIX}/{time.strftime('%Y/%m/%d/%H%M%S', time.gmtime(run_ts_s))}-page{page_index:05d}-bitwarden-events.json"
       s3.put_object(
           Bucket=BUCKET,
           Key=key,
           Body=json.dumps(obj, separators=(",", ":")).encode("utf-8"),
           ContentType="application/json",
       )
       return key
   
   def lambda_handler(event=None, context=None):
       bearer, _ttl = _get_token()
       cont = _read_state()
       run_ts_s = int(time.time())
   
       pages = 0
       written = 0
       while pages < MAX_PAGES:
           data = _fetch_events(bearer, cont)
           # write page
           _write_page(data, run_ts_s, pages)
           pages += 1
   
           # count entries (official shape: {"object":"list","data":[...], "continuationToken": "..."} )
           entries = []
           if isinstance(data.get("data"), list):
               entries = data["data"]
           elif isinstance(data.get("entries"), list):  # fallback if shape differs
               entries = data["entries"]
           written += len(entries)
   
           # next page token (official: "continuationToken")
           next_cont = data.get("continuationToken")
           if next_cont:
               cont = next_cont
               continue
           break
   
       # Save state only if there are more pages to continue in next run
       _write_state(cont if pages >= MAX_PAGES and cont else None)
       return {"ok": True, "pages": pages, "events_estimate": written, "nextContinuationToken": cont}
   
   if __name__ == "__main__":
       print(lambda_handler())
   
   

5. Ve a Configuración > Variables de entorno > Editar > Agregar nueva variable de entorno.

6. Ingresa las siguientes variables de entorno y reemplaza los valores por los tuyos:

   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

7. Después de crear la función, permanece en su página (o abre Lambda > Functions > tu-función).

8. Selecciona la pestaña Configuración.

9. En el panel Configuración general, haz clic en Editar.

10. 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).
   • Destino: Tu función 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. En la consola de AWS, ve a IAM > Usuarios y, luego, haz clic en Agregar usuarios.
2. Proporciona los siguientes detalles de configuración:
   • Usuario: Ingresa un nombre único (por ejemplo, secops-reader).
   • Tipo de acceso: Selecciona Clave de acceso: Acceso programático.
   • Haz clic en Crear usuario.
3. Adjunta una política de lectura mínima (personalizada): Usuarios > selecciona secops-reader > Permisos > Agregar permisos > Adjuntar políticas directamente > Crear política

4. En el editor de JSON, ingresa la siguiente política:

   {
     "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>"
       }
     ]
   }
   

5. Configura el nombre como secops-reader-policy.

6. Ve a Crear política > busca o selecciona > Siguiente > Agregar permisos.

7. Ve a Credenciales de seguridad > Claves de acceso > Crear clave de acceso.

8. Descarga el archivo CSV (estos valores se ingresan en el feed).

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

1. Ve a SIEM Settings > 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 transferencia: 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

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