Collecter les journaux Skyhigh Security CASB (anciennement McAfee Skyhigh CASB)

Compatible avec :

Ce document explique comment ingérer les journaux Skyhigh Security CASB (anciennement McAfee Skyhigh CASB) dans Google Security Operations à l'aide de Google Cloud Storage V2.

Skyhigh Security CASB est un agent de sécurité des accès au cloud (CASB) qui offre visibilité, conformité, sécurité des données et protection contre les menaces pour les services cloud. Il surveille l'activité des utilisateurs dans les environnements SaaS, PaaS et IaaS, détecte les anomalies, applique les règles DLP et génère des journaux d'audit et d'incidents via son API REST.

Avant de commencer

Assurez-vous de remplir les conditions préalables 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 gérer les stratégies IAM sur les buckets GCS
  • Autorisations permettant de créer des services Cloud Run, des sujets Pub/Sub et des jobs Cloud Scheduler
  • Un locataire CASB Skyhigh Security avec accès administrateur
  • Identifiants API de la console Skyhigh Security (ID client et code secret client)
  • Le connecteur Skyhigh Cloud est installé et configuré.

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, skyhigh-casb-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.

Collecter les identifiants de l'API CASB Skyhigh Security

Créer des identifiants client d'API

  1. Connectez-vous à la console Skyhigh Security.
  2. Accédez à Paramètres> Infrastructure> Intégration de l'API.
  3. Cliquez sur Créer un client API.

  4. Saisissez un nom pour le client API (par exemple, Google SecOps Integration).

  5. Sélectionnez les niveaux d'accès suivants :

    • Incidents : accès en lecture aux données d'incidents CASB
    • Anomalies : accès en lecture aux événements d'anomalie
    • Journaux d'audit : accès en lecture à la trace d'audit

  6. Cliquez sur Créer.

  7. Copiez et enregistrez les informations suivantes dans un emplacement sécurisé :

    • ID client : identifiant client généré
    • Code secret du client : code secret du client généré (affiché une seule fois)

Obtenir l'URL de base du locataire

  1. Connectez-vous à la console Skyhigh Security.

  2. Notez l'URL de base dans la barre d'adresse du navigateur. Le format dépend de votre région :

    • États-Unis : https://www.myshn.net
    • UE : https://www.myshn.eu
    • SG : https://www.myshn.sg

Tester l'accès à l'API

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

    # Replace with your actual credentials
CLIENT_ID="your-client-id"
CLIENT_SECRET="your-client-secret"
BASE_URL="https://www.myshn.net"

# Get OAuth 2.0 access token
TOKEN=$(curl -s -X POST "${BASE_URL}/shnapi/rest/external/api/v1/oauth/token" \
    -H "Content-Type: application/x-www-form-urlencoded" \
    -d "grant_type=client_credentials&client_id=${CLIENT_ID}&client_secret=${CLIENT_SECRET}" \
    | python3 -c "import sys,json; print(json.load(sys.stdin)['access_token'])")

# Test API access - list incidents
curl -v -H "Authorization: Bearer ${TOKEN}" \
    "${BASE_URL}/shnapi/rest/external/api/v1/incidents?limit=1"

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 un 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 skyhigh-casb-collector-sa.
    • Description du compte de service : saisissez Service account for Cloud Run function to collect Skyhigh Security CASB 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 Storage : écrire des journaux 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 (par exemple, skyhigh-casb-logs).
  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, skyhigh-casb-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 skyhigh-casb-logs-trigger.
    • Conservez les valeurs par défaut des autres paramètres.

  4. Cliquez sur Créer.

Créer une fonction Cloud Run pour collecter les journaux

La fonction Cloud Run sera déclenchée par les messages Pub/Sub de Cloud Scheduler pour extraire les journaux de l'API CASB Skyhigh Security et les écrire 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 skyhigh-casb-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 skyhigh-casb-logs-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 skyhigh-casb-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 skyhigh-casb-logs Nom du bucket GCS
    GCS_PREFIX skyhigh-casb Préfixe des fichiers journaux
    STATE_KEY skyhigh-casb/state.json Chemin d'accès au fichier d'état
    SKYHIGH_BASE_URL https://www.myshn.net URL de base de Skyhigh Security
    SKYHIGH_CLIENT_ID your-client-id ID client de l'API
    SKYHIGH_CLIENT_SECRET your-client-secret Code secret du client de l'API
    MAX_RECORDS 5000 Nombre maximal d'enregistrements par exécution
    PAGE_SIZE 100 Enregistrements par page
    LOOKBACK_HOURS 24 Période d'analyse initiale

  10. Dans la section Variables et secrets, faites défiler la page jusqu'à Requêtes :

    • Délai avant expiration de la requête : saisissez 600 secondes (10 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 :

    • 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
import urllib.parse

# Initialize HTTP client with timeouts
http = urllib3.PoolManager(
  timeout=urllib3.Timeout(connect=5.0, read=30.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', 'skyhigh-casb')
STATE_KEY = os.environ.get('STATE_KEY', 'skyhigh-casb/state.json')
SKYHIGH_BASE_URL = os.environ.get('SKYHIGH_BASE_URL', '[https://www.myshn.net](https://www.myshn.net)')
SKYHIGH_CLIENT_ID = os.environ.get('SKYHIGH_CLIENT_ID')
SKYHIGH_CLIENT_SECRET = os.environ.get('SKYHIGH_CLIENT_SECRET')
MAX_RECORDS = int(os.environ.get('MAX_RECORDS', '5000'))
PAGE_SIZE = int(os.environ.get('PAGE_SIZE', '100'))
LOOKBACK_HOURS = int(os.environ.get('LOOKBACK_HOURS', '24'))

def get_access_token(base_url: str, client_id: str, client_secret: str) -> str:
  """Get OAuth 2.0 access token from Skyhigh Security."""
  token_url = f"{base_url}/shnapi/rest/external/api/v1/oauth/token"
  body = urllib.parse.urlencode({
    'grant_type': 'client_credentials',
    'client_id': client_id,
    'client_secret': client_secret,
  }).encode('utf-8')

  response = http.request(
    'POST',
    token_url,
    body=body,
    headers={'Content-Type': 'application/x-www-form-urlencoded'},
  )

  if response.status != 200:
    raise Exception(f"Failed to get access token: HTTP {response.status} - {response.data.decode('utf-8')}")

  token_data = json.loads(response.data.decode('utf-8'))
  return token_data['access_token']

@functions_framework.cloud_event
def main(cloud_event):
  """
  Cloud Run function triggered by Pub/Sub to fetch Skyhigh Security CASB
  logs and write to GCS.

  Args:
    cloud_event: CloudEvent object containing Pub/Sub message
  """

  if not all([GCS_BUCKET, SKYHIGH_BASE_URL, SKYHIGH_CLIENT_ID, SKYHIGH_CLIENT_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 any 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)

    print(f"Fetching logs from {last_time.isoformat()} to {now.isoformat()}")

    # Get OAuth token
    access_token = get_access_token(SKYHIGH_BASE_URL, SKYHIGH_CLIENT_ID, SKYHIGH_CLIENT_SECRET)
    print("Successfully obtained access token")

    all_records = []
    newest_time = None

    # Fetch incidents
    incidents, inc_newest = fetch_logs(
      base_url=SKYHIGH_BASE_URL,
      access_token=access_token,
      endpoint_path="/shnapi/rest/external/api/v1/incidents",
      start_time=last_time,
      end_time=now,
      page_size=PAGE_SIZE,
      max_records=MAX_RECORDS,
      log_category="incidents",
    )
    all_records.extend(incidents)
    if inc_newest:
      newest_time = inc_newest

    # Fetch anomalies
    anomalies, anom_newest = fetch_logs(
      base_url=SKYHIGH_BASE_URL,
      access_token=access_token,
      endpoint_path="/shnapi/rest/external/api/v1/anomalies",
      start_time=last_time,
      end_time=now,
      page_size=PAGE_SIZE,
      max_records=MAX_RECORDS,
      log_category="anomalies",
    )
    all_records.extend(anomalies)
    if anom_newest and (newest_time is None or parse_datetime(anom_newest) > parse_datetime(newest_time)):
      newest_time = anom_newest

    if not all_records:
      print("No new log records found.")
      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}/logs_{timestamp}.ndjson"
    blob = bucket.blob(object_key)

    ndjson = '\n'.join([json.dumps(record, ensure_ascii=False) for record in all_records]) + '\n'
    blob.upload_from_string(ndjson, content_type='application/x-ndjson')

    print(f"Wrote {len(all_records)} records to gs://{GCS_BUCKET}/{object_key}")

    # Update state with newest event time
    if newest_time:
      save_state(bucket, STATE_KEY, newest_time)
    else:
      save_state(bucket, STATE_KEY, now.isoformat())

    print(f"Successfully processed {len(all_records)} records")

  except Exception as e:
    print(f'Error processing logs: {str(e)}')
    raise

def parse_datetime(value: str) -> datetime:
  """Parse ISO datetime string to datetime object."""
  if value.endswith("Z"):
    value = value[:-1] + "+00:00"
  return datetime.fromisoformat(value)

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: str):
  """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 fetch_logs(base_url: str, access_token: str, endpoint_path: str, start_time: datetime, end_time: datetime, page_size: int, max_records: int, log_category: str):
  """
  Fetch logs from Skyhigh Security CASB API with pagination
  and rate limiting.

  Args:
    base_url: Skyhigh Security base URL
    access_token: OAuth 2.0 access token
    endpoint_path: API endpoint path
    start_time: Start time for log query
    end_time: End time for log query
    page_size: Number of records per page
    max_records: Maximum total records to fetch
    log_category: Category name for logging

  Returns:
    Tuple of (records list, newest_event_time ISO string)
  """
  endpoint = f"{base_url.rstrip('/')}{endpoint_path}"

  headers = {
    'Authorization': f'Bearer {access_token}',
    'Accept': 'application/json',
    'Content-Type': 'application/json',
    'User-Agent': 'GoogleSecOps-SkyhighCASBCollector/1.0'
  }

  records = []
  newest_time = None
  page_num = 0
  backoff = 1.0
  offset = 0

  start_iso = start_time.strftime('%Y-%m-%dT%H:%M:%SZ')
  end_iso = end_time.strftime('%Y-%m-%dT%H:%M:%SZ')

  while True:
    page_num += 1

    if len(records) >= max_records:
      print(f"Reached max_records limit ({max_records}) for {log_category}")
      break

    limit = min(page_size, max_records - len(records))
    url = f"{endpoint}?start_time={start_iso}&end_time={end_iso}&offset={offset}&limit={limit}"

    try:
      response = http.request('GET', url, headers=headers)

      # Handle rate limiting with exponential backoff
      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, 30.0)
        continue

      backoff = 1.0

      if response.status != 200:
        print(f"HTTP Error: {response.status} for {log_category}")
        response_text = response.data.decode('utf-8')
        print(f"Response body: {response_text}")
        return [], None

      data = json.loads(response.data.decode('utf-8'))

      page_results = data.get('data', data.get('results', data.get('items', [])))

      if not page_results:
        print(f"No more results (empty page) for {log_category}")
        break

      print(f"Page {page_num}: Retrieved {len(page_results)} {log_category} events")
      records.extend(page_results)

      # Track newest event time
      for event in page_results:
        try:
          event_time = event.get('timestamp') or event.get('created_at') or event.get('eventTime')
          if event_time:
            if newest_time is None or parse_datetime(str(event_time)) > parse_datetime(str(newest_time)):
              newest_time = str(event_time)
        except Exception as e:
          print(f"Warning: Could not parse event time: {e}")

      # If we got fewer results than requested, no more pages
      if len(page_results) < limit:
        print(f"Last page reached for {log_category}")
        break

      offset += len(page_results)

    except Exception as e:
      print(f"Error fetching {log_category} logs: {e}")
      return [], None

  print(f"Retrieved {len(records)} total {log_category} records from {page_num} pages")
  return records, newest_time
    • 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 skyhigh-casb-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 skyhigh-casb-logs-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 5 minutes */5 * * * * Volume élevé, faible latence
Toutes les 15 minutes */15 * * * * Volume moyen
Toutes les heures 0 * * * * Standard (recommandé)
Toutes les 6 heures 0 */6 * * * Traitement par lot à faible volume
Tous les jours 0 0 * * * Collecte de données historiques

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 skyhigh-casb-collector.
  6. Cliquez sur l'onglet Journaux.

  7. Vérifiez que la fonction s'est exécutée correctement. Par exemple :

    Fetching logs from YYYY-MM-DDTHH:MM:SS+00:00 to YYYY-MM-DDTHH:MM:SS+00:00
Successfully obtained access token
Page 1: Retrieved X incidents events
Page 1: Retrieved X anomalies events
Wrote X records to gs://skyhigh-casb-logs/skyhigh-casb/logs_YYYYMMDD_HHMMSS.ndjson
Successfully processed X records

  8. Accédez à Cloud Storage > Buckets.

  9. Cliquez sur le nom de votre bucket (skyhigh-casb-logs).

  10. Accédez au dossier skyhigh-casb/.

  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 les identifiants de l'API dans les variables d'environnement ou le jeton peut avoir expiré.
  • HTTP 403 : vérifiez que le client API dispose des niveaux requis dans la console Skyhigh Security
  • HTTP 429 : limitation du débit. La fonction effectuera automatiquement une nouvelle tentative avec un intervalle entre les tentatives.
  • 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 Skyhigh Security CASB

  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, Skyhigh Security CASB Logs).
  5. Sélectionnez Google Cloud Storage V2 comme Type de source.
  6. Sélectionnez McAfee Skyhigh CASB 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.

  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://skyhigh-casb-logs/skyhigh-casb/
      • Remplacez :
        • skyhigh-casb-logs : nom de votre bucket GCS.
        • skyhigh-casb : 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 du 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
EventReceivedTime metadata.event_timestamp Converti en code temporel à partir du format yyyy-MM-dd HH:mm:ss
FileSize target.file.size Mappé directement, converti en uinteger
Nom d'hôte principal.hostname Mappé directement
MessageSourceAddress principal.ip Mappé directement, fusionné s'il existe plusieurs instances
Gravité additional.fields.value.string_value (clé : SEVERITY) Mappé directement
SeverityValue additional.fields.value.string_value (clé : SEVERITY_VALUE) Mappé directement
SourceModuleName additional.fields.value.string_value (clé : SOURCE_MODULE_NAME) Mappé directement
SourceModuleType principal.resource.resource_subtype Mappé directement
SyslogFacility security_result.about.resource.attribute.labels.value (clé : SYSLOG_FACILITY) Mappé directement
SyslogFacilityValue security_result.about.resource.attribute.labels.value (clé : SYSLOG_FACILITY_VALUE) Mappé directement
SyslogSeverity security_result.about.resource.attribute.labels.value (clé : SYSLOG_SEVERITY) Mappé directement
SyslogSeverityValue security_result.about.resource.attribute.labels.value (clé : SYSLOG_SEVERITY_VALUE) Mappé directement
activityName metadata.product_event_type Mappé directement, crochets supprimés
actorId principal.user.userid Mappé directement, également ajouté à email_addresses s'il s'agit d'une adresse e-mail
actorIdType principal.user.attribute.roles.name Mappé directement
collaborationSharedLink security_result.about.resource.attribute.labels.value (key: COLLABORATION_SHARED_LINK) Mappé directement
contentItemId target.file.full_path (si contentItemType est FILE) Mappé directement, citations supprimées
contentItemId target.url (si contentItemType est SAAS_RESOURCE) Mappé directement, citations supprimées
contentItemHierarchy additional.fields.value.string_value (clé : CONTENT_ITEM_HIERARCHY) Mappé directement, citations supprimées
contentItemName target.resource.name Mappé directement, citations supprimées
contentItemType additional.fields.value.string_value (clé : CONTENT_ITEM_TYPE) Mappé directement
incidentGroup security_result.detection_fields.value (clé : INCIDENT_GROUP) Mappé directement
incidentId metadata.product_log_id Mappé directement
incidentRiskScore security_result.detection_fields.value (clé : INCIDENT_RISK_SCORE) Mappé directement
incidentRiskSeverityId Utilisé en combinaison avec riskSeverity pour déterminer security_result.severity
informationAccountId target.resource.product_object_id Mappé directement
informationAnomalyCategory security_result.category_details Mappé directement, citations supprimées
informationAnomalyCause security_result.detection_fields.value (clé : INFO_ANOMALY_CAUSE) Mappé directement, citations supprimées
informationCategory security_result.category_details Mappé directement
informationConfigType additional.fields.value.string_value (key: INFORMATION_CONFIG_TYPE) Mappé directement, citations supprimées
informationContentItemParent target.resource.parent Mappé directement, citations supprimées
informationEventId additional.fields.value.string_value (clé : INFORMATION_EVENT_ID) Mappé directement
informationExternalCollaboratorsCount additional.fields.value.string_value (key: INFORMATION_COLLAB_COUNT) Mappé directement
informationFileTypes additional.fields.value.list_value.values.string_value (clé : FILE_TYPE) Extrait d'une chaîne de type JSON, crochets et guillemets supprimés
informationLastExecutedResponseLabel additional.fields.value.string_value (clé : INFORMATION_LAST_RESPONSE) Mappé directement
informationScanName metadata.description Mappé directement, citations supprimées
informationScanRunDate Non mappé à UDM
informationSource additional.fields.value.string_value (clé : INFORMATION_SOURCE) Mappé directement
informationUniqueMatchCount additional.fields.value.string_value (key: INFORMATION_UNQ_MATCH_COUNT) Mappé directement
informationUserAttributesSAMAccountName principal.user.user_display_name Mappé directement, crochets supprimés
instanceId principal.resource.product_object_id Mappé directement
instanceName principal.resource.name Mappé directement, citations supprimées
policyId security_result.rule_id Mappé directement
policyName security_result.summary Mappé directement, citations supprimées
réponse Utilisé pour déterminer security_result.action (ALLOW ou BLOCK)
riskSeverity Utilisé en combinaison avec incidentRiskSeverityId pour déterminer security_result.severity, converti en majuscules
serviceNames target.application Mappé directement, crochets, guillemets et espaces supplémentaires supprimés
sourceIps principal.ip Extrait d'une chaîne de type JSON, fusionné si plusieurs instances
état additional.fields.value.string_value (clé : STATUS) Mappé directement
threatCategory security_result.threat_name Mappé directement, citations supprimées
totalMatchCount security_result.detection_fields.value (key: TOTAL_MATCH_COUNT) Mappé directement
N/A metadata.vendor_name MCAFEE : valeur statique
N/A metadata.product_name MCAFEE_SKYHIGH_CASB : valeur statique
N/A metadata.log_type MCAFEE_SKYHIGH_CASB : valeur statique
N/A principal.resource.type VIRTUAL_MACHINE : défini si instanceName ou instanceId sont présents
N/A metadata.event_type Déterminé en fonction d'un ensemble de conditions : USER_RESOURCE_UPDATE_CONTENT si actorId, contentItemId ou contentItemName sont présents ; USER_UNCATEGORIZED si actorId et target sont présents ; STATUS_UPDATE si Hostname ou MessageSourceAddress sont présents ; GENERIC_EVENT dans le cas contraire.
N/A security_result.severity Déterminé en fonction de la combinaison de riskSeverity et incidentRiskSeverityId : - LOW si riskSeverity est LOW et incidentRiskSeverityId est 0 - MEDIUM si riskSeverity est MEDIUM et incidentRiskSeverityId est 1 - HIGH si riskSeverity est HIGH et incidentRiskSeverityId est 2 - INFORMATIONAL si riskSeverity est INFO et incidentRiskSeverityId est 3
column2 event.idm.read_only_udm.principal.ip et event.idm.read_only_udm.principal.asset.ip Mappé à partir du journal des modifications
intermediary_host event.idm.read_only_udm.intermediary.hostname et event.idm.read_only_udm.intermediary.asset.hostname Mappé à partir du journal des modifications
column3 event.idm.read_only_udm.network.http.response_code Mappé à partir du journal des modifications
column8 event.idm.read_only_udm.network.received_bytes Mappé à partir du journal des modifications
column9 event.idm.read_only_udm.network.sent_bytes Mappé à partir du journal des modifications
column10 event.idm.read_only_udm.network.http.user_agent Mappé à partir du journal des modifications
column10 event.idm.read_only_udm.network.http.parsed_user_agent Mappé à partir du journal des modifications
http_method event.idm.read_only_udm.network.http.method Mappé à partir du journal des modifications
tar_host event.idm.read_only_udm.target.hostname et event.idm.read_only_udm.target.asset.hostname Mappé à partir du journal des modifications
tar_port event.idm.read_only_udm.target.port Mappé à partir du journal des modifications
application_protocol event.idm.read_only_udm.network.application_protocol Mappé à partir du journal des modifications
tar_url event.idm.read_only_udm.target.url Mappé à partir du journal des modifications
http_version event.idm.read_only_udm.additional.fields Mappé à partir du journal des modifications
column1 event.idm.read_only_udm.additional.fields Mappé à partir du journal des modifications
intermediary_application event.idm.read_only_udm.intermediary.application Mappé à partir du journal des modifications
column5 event.idm.read_only_udm.security_result.category_details Mappé à partir du journal des modifications
column6 event.idm.read_only_udm.security_result.detection_fields Mappé à partir du journal des modifications
column12 event.idm.read_only_udm.security_result.detection_fields Mappé à partir du journal des modifications
column7 event.idm.read_only_udm.target.file.mime_type Mappé à partir du journal des modifications

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.