Collecter les journaux Proofpoint TAP Forensics

Compatible avec :

Ce document explique comment ingérer les journaux Proofpoint TAP Forensics dans Google Security Operations à l'aide de Google Cloud Storage V2.

Proofpoint Targeted Attack Protection (TAP) est une plate-forme avancée de sécurité des e-mails qui détecte, analyse et bloque les menaces transmises par e-mail, y compris les pièces jointes et les URL malveillantes. L'API TAP Forensics fournit des informations détaillées sur les menaces et les campagnes individuelles observées dans votre environnement, y compris les résultats de l'analyse du bac à sable, les indicateurs comportementaux, l'activité réseau, les modifications du système de fichiers et les données d'exécution des processus. Ces indicateurs d'investigation peuvent être utilisés pour confirmer la compromission d'un hôte, enrichir les sources d'informations sur la sécurité ou orchestrer les mises à jour des points de terminaison de sécurité.

Avant de commencer

Assurez-vous de remplir les conditions suivantes :

  • Une instance Google SecOps
  • Un projet GCP avec l'API Cloud Storage activée
  • Autorisations permettant de créer et de gérer des buckets GCS
  • Autorisations permettant de créer des services Cloud Run, des sujets Pub/Sub et des jobs Cloud Scheduler
  • Un abonnement Proofpoint TAP avec accès au tableau de bord Threat Insight
  • Identifiants du service de l'API TAP (principal de service et secret) avec les autorisations d'accès aux API SIEM et Forensics

Générer des identifiants de service pour l'API Proofpoint TAP

  1. Connectez-vous au tableau de bord Proofpoint TAP Threat Insight.
  2. Accédez à Paramètres > Applications connectées > Identifiants de service.
  3. Cliquez sur Créer des identifiants.
  4. Dans la boîte de dialogue Identifiant de service généré, copiez et stockez de manière sécurisée les éléments suivants :

    • Principal de service : identifiant principal utilisé pour l'authentification de l'API
    • Secret : clé secrète utilisée pour l'authentification de l'API

Vérifier l'accès à l'API

  • Testez vos identifiants avant de procéder à l'intégration :

    PRINCIPAL="your-service-principal"
    SECRET="your-secret"
    
    # Test SIEM API access (fetch last 5 minutes of events)
    curl -s "https://tap-api-v2.proofpoint.com/v2/siem/all?format=json&sinceSeconds=300" \
      --user "${PRINCIPAL}:${SECRET}"
    
    # Test Forensics API access (requires a valid threatId)
    # curl -s "https://tap-api-v2.proofpoint.com/v2/forensics?threatId=<threatId>" \
    #   --user "${PRINCIPAL}:${SECRET}"
    

Une réponse réussie de l'API SIEM renvoie un objet JSON contenant les tableaux messagesBlocked, messagesDelivered, clicksBlocked et clicksPermitted.

  • Si vous recevez une erreur 401, vérifiez que votre principal de service et votre secret sont corrects.
  • Si l'erreur 403 s'affiche, vérifiez que l'accès à l'API TAP est activé pour votre compte.

Créer un bucket Google Cloud Storage

  1. Accédez à la console Google Cloud.
  2. Sélectionnez votre projet ou créez-en un.
  3. Dans le menu de navigation, accédez à Cloud Storage > Buckets.
  4. Cliquez sur Créer un bucket.
  5. Fournissez les informations de configuration suivantes :

    Paramètre Valeur
    Attribuez un nom au bucket Saisissez un nom unique (par exemple, proofpoint-tap-forensics-logs).
    Type d'emplacement Choisissez en fonction de vos besoins (région, birégion, multirégion).
    Emplacement Sélectionnez l'emplacement (par exemple, us-central1).
    Classe de stockage Standard (recommandé pour les journaux auxquels vous accédez fréquemment)
    Access control (Contrôle des accès) Uniforme (recommandé)
    Outils de protection Facultatif : Activez la gestion des versions des objets ou la règle de conservation.
  6. Cliquez sur Créer.

Créer un compte de service pour la fonction Cloud Run

La fonction Cloud Run a besoin d'un compte de service disposant des autorisations nécessaires pour écrire dans le bucket GCS et être appelée par Pub/Sub.

Créer le compte de service

  1. Dans la console GCP, accédez à IAM et administration > Comptes de service.
  2. Cliquez sur Créer un compte de service.
  3. Fournissez les informations de configuration suivantes :
    • Nom du compte de service : saisissez tap-forensics-collector-sa.
    • Description du compte de service : saisissez Service account for Cloud Run function to collect Proofpoint TAP Forensics logs.
  4. Cliquez sur Créer et continuer.
  5. Dans la section Autoriser ce compte de service à accéder au projet, ajoutez les rôles suivants :
    1. Cliquez sur Sélectionner un rôle.
    2. Recherchez et sélectionnez Administrateur des objets Storage.
    3. Cliquez sur + Ajouter un autre rôle.
    4. Recherchez et sélectionnez Demandeur Cloud Run.
    5. Cliquez sur + Ajouter un autre rôle.
    6. Recherchez et sélectionnez Demandeur Cloud Functions.
  6. Cliquez sur Continuer.
  7. Cliquez sur OK.

Ces rôles sont requis pour :

  • Administrateur des objets de l'espace de stockage : écrire des données de preuves judiciaires dans un bucket GCS et gérer les fichiers d'état
  • Demandeur Cloud Run : autorise Pub/Sub à appeler la fonction
  • Demandeur Cloud Functions : autorise l'appel de fonctions

Accorder des autorisations IAM sur le bucket GCS

Accordez au compte de service des autorisations d'écriture dans le bucket GCS :

  1. Accédez à Cloud Storage > Buckets.
  2. Cliquez sur le nom de votre bucket.
  3. Accédez à l'onglet Autorisations.
  4. Cliquez sur Accorder l'accès.
  5. Fournissez les informations de configuration suivantes :
    • Ajouter des comptes principaux : saisissez l'adresse e-mail du compte de service (par exemple, tap-forensics-collector-sa@PROJECT_ID.iam.gserviceaccount.com).
    • Attribuer des rôles : sélectionnez Administrateur des objets Storage.
  6. Cliquez sur Enregistrer.

Créer un sujet Pub/Sub

Créez un sujet Pub/Sub auquel Cloud Scheduler publiera des messages et auquel la fonction Cloud Run s'abonnera.

  1. Dans la console GCP, accédez à Pub/Sub > Sujets.
  2. Cliquez sur Créer un sujet.
  3. Fournissez les informations de configuration suivantes :
    • ID du thème : saisissez tap-forensics-collector-trigger.
    • Conservez les valeurs par défaut des autres paramètres.
  4. Cliquez sur Créer.

Créer une fonction Cloud Run pour collecter des preuves médico-légales

La fonction Cloud Run sera déclenchée par les messages Pub/Sub de Cloud Scheduler pour extraire les événements de menace de l'API Proofpoint TAP SIEM, récupérer les preuves médico-légales pour chaque menace unique à l'aide de l'API Forensics et écrire les résultats dans GCS.

  1. Dans la console GCP, accédez à Cloud Run.
  2. Cliquez sur Créer un service.
  3. Sélectionnez Fonction (utilisez un éditeur intégré pour créer une fonction).
  4. Dans la section Configurer, fournissez les informations de configuration suivantes :

    Paramètre Valeur
    Nom du service tap-forensics-collector
    Région Sélectionnez la région correspondant à votre bucket GCS (par exemple, us-central1).
    Durée d'exécution Sélectionnez Python 3.12 ou version ultérieure.
  5. Dans la section Déclencheur (facultatif) :

    1. Cliquez sur + Ajouter un déclencheur.
    2. Sélectionnez Cloud Pub/Sub.
    3. Dans Sélectionner un sujet Cloud Pub/Sub, choisissez le sujet tap-forensics-collector-trigger.
    4. Cliquez sur Enregistrer.
  6. Dans la section Authentification :

    1. Sélectionnez Exiger l'authentification.
    2. Consultez Identity and Access Management (IAM).
  7. Faites défiler la page vers le bas, puis développez Conteneurs, mise en réseau, sécurité.

  8. Accédez à l'onglet Sécurité :

    • Compte de service : sélectionnez le compte de service tap-forensics-collector-sa
  9. Accédez à l'onglet Conteneurs :

    1. Cliquez sur Variables et secrets.
    2. Cliquez sur + Ajouter une variable pour chaque variable d'environnement :
    Nom de la variable Exemple de valeur Description
    GCS_BUCKET proofpoint-tap-forensics-logs Nom du bucket GCS
    GCS_PREFIX tap-forensics Préfixe des fichiers journaux
    STATE_KEY tap-forensics/state.json Chemin d'accès au fichier d'état
    TAP_PRINCIPAL your-service-principal Principal de service de l'API TAP
    TAP_SECRET your-secret Code secret de l'API TAP
    LOOKBACK_HOURS 1 Période d'analyse initiale en heures (7 jours maximum)
    MAX_THREATS 500 Nombre maximal de menaces uniques pour lesquelles récupérer des informations d'analyse par exécution
  10. Dans la section Variables et secrets, faites défiler la page jusqu'à Requêtes :

    • Délai avant expiration de la requête : saisissez 540 secondes (9 minutes).
  11. Accédez à l'onglet Paramètres :

    • Dans la section Ressources :
      • Mémoire : sélectionnez 512 Mio ou plus.
      • CPU : sélectionnez 1.
  12. Dans la section Scaling de révision :

    • Nombre minimal d'instances : saisissez 0.
    • Nombre maximal d'instances : saisissez 100 (ou ajustez en fonction de la charge attendue).
  13. Cliquez sur Créer.

  14. Attendez que le service soit créé (une à deux minutes).

  15. Une fois le service créé, l'éditeur de code intégré s'ouvre automatiquement.

Ajouter un code de fonction

  1. Saisissez main dans le champ Point d'entrée.
  2. Dans l'éditeur de code intégré, créez deux fichiers :

    • Premier fichier : main.py:

      import functions_framework
      from google.cloud import storage
      import json
      import os
      import urllib3
      from datetime import datetime, timezone, timedelta
      import time
      import base64
      
      # Initialize HTTP client with timeouts
      http = urllib3.PoolManager(
        timeout=urllib3.Timeout(connect=10.0, read=60.0),
        retries=False,
      )
      
      # Initialize Storage client
      storage_client = storage.Client()
      
      # Environment variables
      GCS_BUCKET = os.environ.get('GCS_BUCKET')
      GCS_PREFIX = os.environ.get('GCS_PREFIX', 'tap-forensics').strip('/')
      STATE_KEY = os.environ.get('STATE_KEY') or f"{GCS_PREFIX}/state.json"
      TAP_PRINCIPAL = os.environ.get('TAP_PRINCIPAL')
      TAP_SECRET = os.environ.get('TAP_SECRET')
      LOOKBACK_HOURS = int(os.environ.get('LOOKBACK_HOURS', '1'))
      MAX_THREATS = int(os.environ.get('MAX_THREATS', '500'))
      
      API_BASE = 'https://tap-api-v2.proofpoint.com'
      
      def get_auth_header():
        """Build HTTP Basic Authentication header."""
        auth_string = f"{TAP_PRINCIPAL}:{TAP_SECRET}"
        auth_bytes = auth_string.encode('utf-8')
        auth_b64 = base64.b64encode(auth_bytes).decode('utf-8')
        return f"Basic {auth_b64}"
      
      @functions_framework.cloud_event
      def main(cloud_event):
        """
        Cloud Run function triggered by Pub/Sub to fetch Proofpoint TAP
        forensic evidence and write to GCS.
      
        The function first queries the SIEM API to discover threat IDs,
        then calls the Forensics API for each unique threat to retrieve
        detailed forensic evidence (sandbox results, behavioral
        indicators, network activity, file changes, and process data).
      
        Args:
          cloud_event: CloudEvent object containing Pub/Sub message
        """
      
        if not all([GCS_BUCKET, TAP_PRINCIPAL, TAP_SECRET]):
          print('Error: Missing required environment variables')
          return
      
        try:
          bucket = storage_client.bucket(GCS_BUCKET)
      
          # Load state
          state = load_state(bucket, STATE_KEY)
      
          # Determine time window
          now = datetime.now(timezone.utc)
          last_time = None
      
          if isinstance(state, dict) and state.get('last_event_time'):
            try:
              last_time = parse_datetime(state['last_event_time'])
              # Overlap by 2 minutes to catch delayed events
              last_time = last_time - timedelta(minutes=2)
            except Exception as e:
              print(f"Warning: Could not parse last_event_time: {e}")
      
          if last_time is None:
            last_time = now - timedelta(hours=LOOKBACK_HOURS)
      
          # TAP SIEM API allows max 1 hour per request and max 7 days lookback
          if (now - last_time) > timedelta(days=7):
            last_time = now - timedelta(days=7)
            print("Warning: Lookback capped to 7 days (TAP API limit)")
      
          print(f"Fetching threats from {last_time.isoformat()} to {now.isoformat()}")
      
          # Step 1: Fetch threat IDs from the SIEM API
          threat_ids = fetch_threat_ids(last_time, now)
      
          if not threat_ids:
            print("No threats found in the specified time window.")
            save_state(bucket, STATE_KEY, now.isoformat())
            return
      
          print(f"Found {len(threat_ids)} unique threat IDs")
      
          # Step 2: Fetch forensic evidence for each threat
          forensic_records = fetch_forensics_for_threats(threat_ids)
      
          if not forensic_records:
            print("No forensic evidence retrieved.")
            save_state(bucket, STATE_KEY, now.isoformat())
            return
      
          # Write to GCS as NDJSON
          timestamp = now.strftime('%Y%m%d_%H%M%S')
          object_key = f"{GCS_PREFIX}/tap_forensics_{timestamp}.ndjson"
          blob = bucket.blob(object_key)
      
          ndjson = '\n'.join(
            [json.dumps(record, ensure_ascii=False) for record in forensic_records]
          ) + '\n'
          blob.upload_from_string(ndjson, content_type='application/x-ndjson')
      
          print(f"Wrote {len(forensic_records)} records to gs://{GCS_BUCKET}/{object_key}")
      
          # Update state
          save_state(bucket, STATE_KEY, now.isoformat())
      
          print(f"Successfully processed forensics for {len(threat_ids)} threats")
      
        except Exception as e:
          print(f'Error processing TAP forensics: {str(e)}')
          raise
      
      def load_state(bucket, key):
        """Load state from GCS."""
        try:
          blob = bucket.blob(key)
          if blob.exists():
            state_data = blob.download_as_text()
            return json.loads(state_data)
        except Exception as e:
          print(f"Warning: Could not load state: {e}")
        return {}
      
      def save_state(bucket, key, last_event_time_iso):
        """Save the last event timestamp to GCS state file."""
        try:
          state = {'last_event_time': last_event_time_iso}
          blob = bucket.blob(key)
          blob.upload_from_string(
            json.dumps(state, indent=2),
            content_type='application/json'
          )
          print(f"Saved state: last_event_time={last_event_time_iso}")
        except Exception as e:
          print(f"Warning: Could not save state: {e}")
      
      def parse_datetime(value):
        """Parse ISO datetime string to datetime object."""
        if value.endswith('Z'):
          value = value[:-1] + '+00:00'
        return datetime.fromisoformat(value)
      
      def fetch_threat_ids(start_time, end_time):
        """
        Fetch unique threat IDs from the TAP SIEM API by querying
        in 1-hour intervals within the specified time window.
      
        Args:
          start_time: Start of the time window (datetime)
          end_time: End of the time window (datetime)
      
        Returns:
          Set of unique threat ID strings
        """
        headers = {
          'Authorization': get_auth_header(),
          'Accept': 'application/json',
          'User-Agent': 'GoogleSecOps-TAPForensicsCollector/1.0',
        }
      
        threat_ids = set()
        current_start = start_time
        backoff = 1.0
      
        while current_start < end_time:
          # TAP SIEM API allows max 1 hour per request
          current_end = min(current_start + timedelta(hours=1), end_time)
      
          interval = (
            f"{current_start.strftime('%Y-%m-%dT%H:%M:%SZ')}"
            f"/{current_end.strftime('%Y-%m-%dT%H:%M:%SZ')}"
          )
          url = f"{API_BASE}/v2/siem/all?format=json&interval={interval}"
      
          try:
            response = http.request('GET', url, headers=headers)
      
            if response.status == 429:
              retry_after = int(
                response.headers.get('Retry-After', str(int(backoff)))
              )
              print(f"Rate limited (429). Retrying after {retry_after}s...")
              time.sleep(retry_after)
              backoff = min(backoff * 2, 60.0)
              continue
      
            backoff = 1.0
      
            if response.status != 200:
              print(f"SIEM API HTTP Error: {response.status}")
              response_text = response.data.decode('utf-8')
              print(f"Response body: {response_text[:500]}")
              current_start = current_end
              continue
      
            data = json.loads(response.data.decode('utf-8'))
      
            # Extract threat IDs from all event types
            for key in ['messagesBlocked', 'messagesDelivered']:
              for msg in data.get(key, []):
                for threat_info in msg.get('threatsInfoMap', []):
                  tid = threat_info.get('threatID')
                  if tid:
                    threat_ids.add(tid)
      
            for key in ['clicksBlocked', 'clicksPermitted']:
              for click in data.get(key, []):
                tid = click.get('threatID')
                if tid:
                  threat_ids.add(tid)
      
            event_count = sum(
              len(data.get(k, []))
              for k in [
                'messagesBlocked',
                'messagesDelivered',
                'clicksBlocked',
                'clicksPermitted',
              ]
            )
            print(
              f"Interval {interval}: {event_count} events, "
              f"{len(threat_ids)} unique threats so far"
            )
      
          except Exception as e:
            print(f"Error fetching SIEM events: {e}")
      
          current_start = current_end
      
          if len(threat_ids) >= MAX_THREATS:
            print(f"Reached max threats limit ({MAX_THREATS})")
            break
      
        return threat_ids
      
      def fetch_forensics_for_threats(threat_ids):
        """
        Fetch forensic evidence for each threat ID from the
        Forensics API.
      
        Args:
          threat_ids: Set of threat ID strings
      
        Returns:
          List of forensic report dictionaries
        """
        headers = {
          'Authorization': get_auth_header(),
          'Accept': 'application/json',
          'User-Agent': 'GoogleSecOps-TAPForensicsCollector/1.0',
        }
      
        records = []
        backoff = 1.0
        processed = 0
        skipped = 0
      
        for threat_id in list(threat_ids)[:MAX_THREATS]:
          url = (
            f"{API_BASE}/v2/forensics"
            f"?threatId={threat_id}"
            f"&includeCampaignForensics=true"
          )
      
          try:
            response = http.request('GET', url, headers=headers)
      
            if response.status == 429:
              retry_after = int(
                response.headers.get('Retry-After', str(int(backoff)))
              )
              print(f"Rate limited (429). Retrying after {retry_after}s...")
              time.sleep(retry_after)
              backoff = min(backoff * 2, 60.0)
              # Retry the same threat
              continue
      
            backoff = 1.0
      
            if response.status == 204:
              skipped += 1
              processed += 1
              continue
      
            if response.status != 200:
              print(
                f"Forensics API error for {threat_id}: "
                f"HTTP {response.status}"
              )
              skipped += 1
              processed += 1
              continue
      
            data = json.loads(response.data.decode('utf-8'))
            reports = data.get('reports', [])
      
            if reports:
              # Add the threat ID to each report for correlation
              for report in reports:
                report['_threatId'] = threat_id
              records.extend(reports)
      
            processed += 1
      
            if processed % 50 == 0:
              print(
                f"Progress: {processed}/{len(threat_ids)} threats, "
                f"{len(records)} forensic reports collected"
              )
      
          except Exception as e:
            print(f"Error fetching forensics for {threat_id}: {e}")
            skipped += 1
            processed += 1
      
        print(
          f"Forensics collection complete: {processed} threats processed, "
          f"{skipped} skipped, {len(records)} reports collected"
        )
        return records
      
    • Deuxième fichier : requirements.txt:

      functions-framework==3.*
      google-cloud-storage==2.*
      urllib3>=2.0.0
      
  3. Cliquez sur Déployer pour enregistrer et déployer la fonction.

  4. Attendez la fin du déploiement (deux à trois minutes).

Créer une tâche Cloud Scheduler

Cloud Scheduler publiera des messages dans le sujet Pub/Sub à intervalles réguliers, ce qui déclenchera la fonction Cloud Run.

  1. Dans la console GCP, accédez à Cloud Scheduler.
  2. Cliquez sur Créer une tâche.
  3. Fournissez les informations de configuration suivantes :

    Paramètre Valeur
    Nom tap-forensics-collector-hourly
    Région Sélectionnez la même région que la fonction Cloud Run.
    Fréquence 0 * * * * (toutes les heures, à l'heure pile)
    Fuseau horaire Sélectionnez un fuseau horaire (UTC recommandé).
    Type de cible Pub/Sub
    Sujet Sélectionnez le thème tap-forensics-collector-trigger.
    Corps du message {} (objet JSON vide)
  4. Cliquez sur Créer.

Options de fréquence de programmation

Choisissez la fréquence en fonction du volume de journaux et des exigences de latence :

Fréquence Expression Cron Cas d'utilisation
Toutes les 15 minutes */15 * * * * Environnements à fort volume avec de nombreuses menaces
Toutes les heures 0 * * * * Standard (recommandé)
Toutes les 6 heures 0 */6 * * * Environnements à faible volume

Tester l'intégration

  1. Dans la console Cloud Scheduler, recherchez votre job.
  2. Cliquez sur Exécuter de force pour déclencher le job manuellement.
  3. Patientez quelques secondes.
  4. Accédez à Cloud Run > Services.
  5. Cliquez sur le nom de la fonction tap-forensics-collector.
  6. Cliquez sur l'onglet Journaux.
  7. Vérifiez que la fonction s'est exécutée correctement. Par exemple :

    Fetching threats from YYYY-MM-DDTHH:MM:SS+00:00 to YYYY-MM-DDTHH:MM:SS+00:00
    Interval .../...: X events, Y unique threats so far
    Found Z unique threat IDs
    Forensics collection complete: Z threats processed, 0 skipped, N reports collected
    Wrote N records to gs://proofpoint-tap-forensics-logs/tap-forensics/tap_forensics_YYYYMMDD_HHMMSS.ndjson
    Successfully processed forensics for Z threats
    
  8. Accédez à Cloud Storage > Buckets.

  9. Cliquez sur le nom de votre bucket.

  10. Accédez au dossier de préfixe tap-forensics/.

  11. Vérifiez qu'un nouveau fichier .ndjson a été créé avec l'horodatage actuel.

Si des erreurs s'affichent dans les journaux :

  • HTTP 401 : vérifiez TAP_PRINCIPAL et TAP_SECRET dans les variables d'environnement. Vérifiez que le principal de service et le code secret sont corrects.
  • HTTP 403 : vérifiez que l'accès à l'API est activé pour votre compte TAP.
  • HTTP 429 : limitation du débit. La fonction effectuera automatiquement une nouvelle tentative avec un intervalle entre les tentatives. Envisagez de réduire la fréquence de programmation.
  • Aucune menace détectée : ce message est normal si aucune menace n'a été détectée au cours de la période. TAP ne signale que les menaces identifiées par URL Defense ou Attachment Defense.
  • Variables d'environnement manquantes : vérifiez que toutes les variables requises sont définies.

Configurer un flux dans Google SecOps pour ingérer les journaux Proofpoint TAP Forensics

  1. Accédez à Paramètres SIEM> Flux.
  2. Cliquez sur Ajouter un flux.
  3. Cliquez sur Configurer un flux unique.
  4. Dans le champ Nom du flux, saisissez un nom pour le flux (par exemple, Proofpoint TAP Forensics).
  5. Sélectionnez Google Cloud Storage V2 comme Type de source.
  6. Sélectionnez Proofpoint Tap Forensics comme Type de journal.
  7. Cliquez sur Obtenir un compte de service. Une adresse e-mail de compte de service unique s'affiche, par exemple :

    chronicle-12345678@chronicle-gcp-prod.iam.gserviceaccount.com
    
  8. Copiez cette adresse e-mail pour l'utiliser à l'étape suivante.

  9. Cliquez sur Suivant.

  10. Spécifiez les valeurs des paramètres d'entrée suivants :

    • URL du bucket de stockage : saisissez l'URI du bucket GCS avec le chemin d'accès au préfixe :

      gs://proofpoint-tap-forensics-logs/tap-forensics/
      
      • Remplacez :
        • proofpoint-tap-forensics-logs : nom de votre bucket GCS.
        • tap-forensics : préfixe/chemin d'accès au dossier facultatif où les journaux sont stockés (laisser vide pour la racine).
    • Option de suppression de la source : sélectionnez l'option de suppression de votre choix :

      • Jamais : ne supprime jamais aucun fichier après les transferts (recommandé pour les tests).
      • Supprimer les fichiers transférés : supprime les fichiers une fois le transfert réussi.
      • Supprimer les fichiers transférés et les répertoires vides : supprime les fichiers et les répertoires vides une fois le transfert réussi.
    • Âge maximal du fichier : incluez les fichiers modifiés au cours des derniers jours (180 jours par défaut).

    • Espace de noms de l'élément : espace de noms de l'élément

    • Libellés d'ingestion : libellé à appliquer aux événements de ce flux

  11. Cliquez sur Suivant.

  12. Vérifiez la configuration de votre nouveau flux sur l'écran Finaliser, puis cliquez sur Envoyer.

Accorder des autorisations IAM au compte de service Google SecOps

Le compte de service Google SecOps a besoin du rôle Lecteur des objets Storage sur votre bucket GCS.

  1. Accédez à Cloud Storage > Buckets.
  2. Cliquez sur le nom de votre bucket.
  3. Accédez à l'onglet Autorisations.
  4. Cliquez sur Accorder l'accès.
  5. Fournissez les informations de configuration suivantes :
    • Ajouter des comptes principaux : collez l'adresse e-mail du compte de service Google SecOps.
    • Attribuer des rôles : sélectionnez Lecteur d'objets Storage.
  6. Cliquez sur Enregistrer.

Table de mappage UDM

Champ de journal Mappage UDM Logique
malicious_label additional.fields Fusionné
threat_type_label additional.fields Fusionné
generated metadata.event_timestamp Analysé en tant que ISO8601
has_principal metadata.event_type Mappé : true → STATUS_UPDATE
protocol network.ip_protocol Mappé directement
prin_ip principal.asset.ip Fusionné
domain principal.domain.name Mappé directement
path principal.file.full_path Mappé directement
file_hash_sha256 principal.file.sha256 Mappé directement
prin_ip principal.ip Fusionné
port principal.port Mappé directement
url principal.url Mappé directement
_security_result security_result Fusionné
N/A metadata.event_type Constante : STATUS_UPDATE
N/A metadata.product_event_type Constante : Forensic Reports
N/A metadata.product_name Constante : TAP Forensics
N/A metadata.vendor_name Constante : Proofpoint
N/A principal.asset.platform_software.platform Constante : WINDOWS

Journal des modifications

Afficher le journal des modifications pour ce parseur

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