Intel 471 Watcher Alerts のログを収集する

以下でサポートされています。

このドキュメントでは、Google Cloud Storage V2 を使用して Intel 471 Watcher Alerts ログを Google Security Operations に取り込む方法について説明します。

Intel 471 は、アンダーグラウンド経済から得られた攻撃者とマルウェアに関するインテリジェンスを提供するサイバー脅威インテリジェンス企業です。Watcher アラートは、Intel 471 の Titan プラットフォームによって生成される通知です。お客様が定義した Watcher の条件に一致する新しいコンテンツが検出されると、アクターの活動、フォーラム投稿、マルウェア インテリジェンスなどの関連する脅威をタイムリーに把握できます。

始める前に

次の前提条件を満たしていることを確認します。

  • Google SecOps インスタンス
  • Cloud Storage API が有効になっている GCP プロジェクト
  • GCS バケットを作成および管理する権限
  • GCS バケットの IAM ポリシーを管理する権限
  • Cloud Run サービス、Pub/Sub トピック、Cloud Scheduler ジョブを作成する権限
  • API アクセスが有効になっている有効な Intel 471 Titan サブスクリプション
  • Intel 471 Titan ポータルへの特権アクセス

Google Cloud Storage バケットを作成する

  1. Google Cloud コンソールに移動します。
  2. プロジェクトを選択するか、新しいプロジェクトを作成します。
  3. ナビゲーション メニューで、[Cloud Storage] > [バケット] に移動します。
  4. [バケットを作成] をクリックします。

  5. 次の構成情報を提供してください。

    設定 値
    バケットに名前を付ける グローバルに一意の名前（intel471-watcher-alerts-logs など）を入力します。
    ロケーション タイプ ニーズに応じて選択します（リージョン、デュアルリージョン、マルチリージョン）。
    ロケーション ロケーションを選択します（例: us-central1）。
    ストレージ クラス Standard（アクセス頻度の高いログにおすすめ）
    アクセス制御 均一（推奨）
    保護ツール 省略可: オブジェクトのバージョニングまたは保持ポリシーを有効にする

  6. [作成] をクリックします。

Intel 471 Titan API 認証情報を収集する

API 認証情報を取得する

  1. Intel 471 Titan ポータルにログインします。
  2. 右上にあるユーザー プロフィール アイコンをクリックします。
  3. [API] セクションに移動します。
  4. ページに表示された API キーをコピーして保存します。
  5. Intel 471 アカウントに関連付けられているメールアドレス（ログインに使用したメールアドレス）をメモします。

権限を確認する

アカウントに必要な権限があることを確認するには:

  1. Intel 471 Titan ポータルにログインします。
  2. ナビゲーション メニューの [Watchers] に移動します。
  3. 既存の Watcher 構成とアラートを表示できる場合は、必要な権限が付与されています。
  4. このセクションが表示されない場合は、Intel 471 管理者に連絡して、API アクセスと Watcher 権限を付与してもらいます。

テスト API へのアクセス

  • 統合に進む前に、認証情報をテストします。

    # Replace with your actual credentials
INTEL471_EMAIL="your-email@example.com"
INTEL471_API_KEY="your-api-key"

# Test API access
curl -v -u "${INTEL471_EMAIL}:${INTEL471_API_KEY}" \
    "https://api.intel471.com/v1/alerts?count=1"

テストが成功すると、alerts 配列を含む JSON レスポンスが返されます。エラーが表示された場合:

  • HTTP 401: メールアドレスと API キーが正しいことを確認します。
  • HTTP 403: アカウントに Watcher アラートの権限があることを確認する
  • HTTP 429: レート制限を超えました。しばらく待ってから再試行してください

Cloud Run functions のサービス アカウントを作成する

Cloud Run functions には、GCS バケットへの書き込み権限があり、Pub/Sub によって呼び出されるサービス アカウントが必要です。

サービス アカウントの作成

  1. GCP Console で、[IAM と管理] > [サービス アカウント] に移動します。
  2. [サービス アカウントを作成] をクリックします。
  3. 次の構成情報を指定します。
    • サービス アカウント名: 「intel471-alerts-collector-sa」と入力します。
    • サービス アカウントの説明: 「Service account for Cloud Run function to collect Intel 471 Watcher Alerts logs」と入力します。
  4. [作成して続行] をクリックします。
  5. [このサービス アカウントにプロジェクトへのアクセスを許可する] セクションで、次のロールを追加します。
    1. [ロールを選択] をクリックします。
    2. [ストレージ オブジェクト管理者] を検索して選択します。
    3. [+ 別のロールを追加] をクリックします。
    4. [Cloud Run 起動元] を検索して選択します。
    5. [+ 別のロールを追加] をクリックします。
    6. [Cloud Functions 起動元] を検索して選択します。
  6. [続行] をクリックします。
  7. [完了] をクリックします。

これらのロールは、次の操作に必要です。

  • Storage オブジェクト管理者: ログを GCS バケットに書き込み、状態ファイルを管理する
  • Cloud Run 起動元: Pub/Sub が関数を呼び出すことを許可します。
  • Cloud Functions 起動元: 関数の呼び出しを許可します。

GCS バケットに対する IAM 権限を付与する

GCS バケットに対する書き込み権限をサービス アカウントに付与します。

  1. [Cloud Storage] > [バケット] に移動します。
  2. バケット名（intel471-watcher-alerts-logs など）をクリックします。
  3. [権限] タブに移動します。
  4. [アクセス権を付与] をクリックします。
  5. 次の構成情報を指定します。
    • プリンシパルを追加: サービス アカウントのメールアドレス（例: intel471-alerts-collector-sa@PROJECT_ID.iam.gserviceaccount.com）を入力します。
    • ロールを割り当てる: [ストレージ オブジェクト管理者] を選択します。
  6. [保存] をクリックします。

Pub/Sub トピックの作成

Cloud Scheduler がパブリッシュし、Cloud Run 関数がサブスクライブする Pub/Sub トピックを作成します。

  1. GCP コンソールで、[Pub/Sub] > [トピック] に移動します。
  2. [トピックを作成] をクリックします。
  3. 次の構成情報を指定します。
    • トピック ID: 「intel471-alerts-trigger」と入力します。
    • その他の設定はデフォルトのままにします。
  4. [作成] をクリックします。

ログを収集する Cloud Run 関数を作成する

Cloud Run 関数は、Cloud Scheduler からの Pub/Sub メッセージによってトリガーされ、Intel 471 Titan API から Watcher アラートを取得して GCS に書き込みます。

  1. GCP Console で、[Cloud Run] に移動します。
  2. [サービスを作成] をクリックします。
  3. [関数]（インライン編集を使用して関数を作成する）を選択します。

  4. [構成] セクションで、次の構成の詳細を指定します。

    設定 値
    サービス名 intel471-alerts-collector
    リージョン GCS バケットと一致するリージョンを選択します（例: us-central1）。
    ランタイム [Python 3.12] 以降を選択します。

  5. [トリガー（省略可）] セクションで、次の操作を行います。

    1. [+ トリガーを追加] をクリックします。
    2. [Cloud Pub/Sub] を選択します。
    3. [Cloud Pub/Sub トピックを選択してください] で、Pub/Sub トピック（intel471-alerts-trigger など）を選択します。
    4. [保存] をクリックします。

  6. [認証] セクションで、次の操作を行います。

    1. [認証が必要] を選択します。
    2. Identity and Access Management（IAM）を確認します。

  7. 下にスクロールして、[コンテナ、ネットワーキング、セキュリティ] を開きます。

  8. [セキュリティ] タブに移動します。

    • サービス アカウント: サービス アカウント（intel471-alerts-collector-sa など）を選択します。

  9. [コンテナ] タブに移動します。

    1. [変数とシークレット] をクリックします。

    2. 環境変数ごとに [+ 変数を追加] をクリックします。

      変数名 値の例 説明
      GCS_BUCKET intel471-watcher-alerts-logs GCS バケット名
      GCS_PREFIX intel471-alerts ログファイルの接頭辞
      STATE_KEY intel471-alerts/state.json 状態ファイルのパス
      INTEL471_EMAIL your-email@example.com Intel 471 アカウントのメールアドレス
      INTEL471_API_KEY your-api-key Intel 471 API キー
      MAX_RECORDS 1000 1 回の実行あたりの最大レコード数
      PAGE_SIZE 100 1 ページあたりのレコード数（最大 100）
      LOOKBACK_HOURS 24 最初のルックバック期間

  10. [変数とシークレット] セクションで、[リクエスト] まで下にスクロールします。

    • リクエストのタイムアウト: 600 秒（10 分）を入力します。

  11. [設定] タブに移動します。

    • [リソース] セクションで次の操作を行います。
      • メモリ: 512 MiB 以上を選択します。
      • CPU: 1 を選択します。

  12. [リビジョン スケーリング] セクションで、次の操作を行います。

    • [インスタンスの最小数]: 「0」と入力します。
    • インスタンスの最大数: 100 と入力します（または、予想される負荷に基づいて調整します）。

  13. [作成] をクリックします。

  14. サービスが作成されるまで待ちます（1 ～ 2 分）。サービスを作成すると、インライン コードエディタが自動的に開きます。

関数コードを追加する

  1. [エントリ ポイント] フィールドに「main」と入力します。

  2. インライン コードエディタで、次の 2 つのファイルを作成します。

    • 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=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', 'intel471-alerts')
STATE_KEY = os.environ.get('STATE_KEY', 'intel471-alerts/state.json')
INTEL471_EMAIL = os.environ.get('INTEL471_EMAIL')
INTEL471_API_KEY = os.environ.get('INTEL471_API_KEY')
MAX_RECORDS = int(os.environ.get('MAX_RECORDS', '1000'))
PAGE_SIZE = int(os.environ.get('PAGE_SIZE', '100'))
LOOKBACK_HOURS = int(os.environ.get('LOOKBACK_HOURS', '24'))

API_BASE = 'https://api.intel471.com/v1'

def to_unix_millis(dt: datetime) -> int:
    """Convert datetime to Unix epoch milliseconds."""
    if dt.tzinfo is None:
        dt = dt.replace(tzinfo=timezone.utc)
    dt = dt.astimezone(timezone.utc)
    return int(dt.timestamp() * 1000)

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)

@functions_framework.cloud_event
def main(cloud_event):
    """
    Cloud Run function triggered by Pub/Sub to fetch Intel 471 Watcher Alerts and write to GCS.

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

    if not all([GCS_BUCKET, INTEL471_EMAIL, INTEL471_API_KEY]):
        print('Error: Missing required environment variables')
        return

    try:
        # Get GCS bucket
        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 alerts from {last_time.isoformat()} to {now.isoformat()}")

        # Convert to Unix milliseconds for Titan API
        start_millis = to_unix_millis(last_time)
        end_millis = to_unix_millis(now)

        # Fetch alerts
        records, newest_event_time = fetch_alerts(
            email=INTEL471_EMAIL,
            api_key=INTEL471_API_KEY,
            start_millis=start_millis,
            end_millis=end_millis,
            page_size=PAGE_SIZE,
            max_records=MAX_RECORDS,
        )

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

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

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

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

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

    except Exception as e:
        print(f'Error processing alerts: {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: 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_alerts(email: str, api_key: str, start_millis: int, end_millis: int, page_size: int, max_records: int):
    """
    Fetch Watcher Alerts from Intel 471 Titan API with pagination and rate limiting.

    Args:
        email: Intel 471 account email
        api_key: Intel 471 API key
        start_millis: Start time in Unix epoch milliseconds
        end_millis: End time in Unix epoch milliseconds
        page_size: Number of records per page (max 100)
        max_records: Maximum total records to fetch

    Returns:
        Tuple of (records list, newest_event_time ISO string)
    """
    endpoint = f"{API_BASE}/alerts"

    # Build Basic Auth header
    auth_string = f"{email}:{api_key}"
    auth_bytes = auth_string.encode('utf-8')
    auth_b64 = base64.b64encode(auth_bytes).decode('utf-8')

    headers = {
        'Authorization': f'Basic {auth_b64}',
        'Accept': 'application/json',
        'User-Agent': 'GoogleSecOps-Intel471Collector/1.0'
    }

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

    while True:
        page_num += 1

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

        # Build request URL with pagination and time filtering
        current_page_size = min(page_size, max_records - len(records))
        params = []
        params.append(f"count={current_page_size}")
        params.append(f"offset={offset}")
        params.append(f"from={start_millis}")
        params.append(f"until={end_millis}")
        url = f"{endpoint}?{'&'.join(params)}"

        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, 60.0)
                continue

            backoff = 1.0

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

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

            # Extract results from alerts
            page_results = data.get('alerts', [])

            if not page_results:
                print(f"No more results (empty page)")
                break

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

            # Track newest event time using foundTime (Unix milliseconds)
            for alert in page_results:
                try:
                    found_time_ms = alert.get('foundTime')
                    if found_time_ms:
                        event_dt = datetime.fromtimestamp(found_time_ms / 1000, tz=timezone.utc)
                        event_time = event_dt.isoformat()
                        if newest_time is None or parse_datetime(event_time) > parse_datetime(newest_time):
                            newest_time = event_time
                except Exception as e:
                    print(f"Warning: Could not parse event time: {e}")

            # Check for more results
            alert_total = data.get('alertTotalCount', 0)
            if len(records) >= alert_total:
                print(f"Retrieved all available alerts ({alert_total} total)")
                break

            if len(page_results) < current_page_size:
                print(f"Reached last page (size={len(page_results)} < limit={current_page_size})")
                break

            offset += len(page_results)

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

    print(f"Retrieved {len(records)} total records from {page_num} pages")
    return records, newest_time

    • requirements.txt:

      functions-framework==3.*
google-cloud-storage==2.*
urllib3>=2.0.0

  3. [デプロイ] をクリックして、関数を保存してデプロイします。

  4. デプロイが完了するまで待ちます（2 ～ 3 分）。

Cloud Scheduler ジョブの作成

Cloud Scheduler は、定期的に Pub/Sub トピックにメッセージをパブリッシュし、Cloud Run 関数をトリガーします。

  1. GCP Console で、[Cloud Scheduler] に移動します。
  2. [ジョブを作成] をクリックします。

  3. 次の構成情報を提供してください。

    設定 値
    名前 intel471-alerts-collector-hourly
    リージョン Cloud Run functions と同じリージョンを選択する
    周波数 0 * * * *（1 時間ごと、毎正時）
    タイムゾーン タイムゾーンを選択（UTC を推奨）
    ターゲット タイプ Pub/Sub
    トピック Pub/Sub トピック（intel471-alerts-trigger など）を選択します。
    メッセージ本文 {}（空の JSON オブジェクト）

  4. [作成] をクリックします。

スケジュール頻度のオプション

アラートの量とレイテンシの要件に基づいて頻度を選択します。

頻度 CRON 式 ユースケース
5 分おき */5 * * * * 大容量、低レイテンシ
15 分ごと */15 * * * * 検索量が普通
1 時間ごと 0 * * * * 標準（推奨）
6 時間ごと 0 */6 * * * 少量、バッチ処理
毎日 0 0 * * * 過去のデータの収集

統合をテストする

  1. Cloud Scheduler コンソールで、ジョブ（intel471-alerts-collector-hourly など）を見つけます。
  2. [強制実行] をクリックして、ジョブを手動でトリガーします。
  3. 数秒待ちます。
  4. Cloud Run > [サービス] に移動します。
  5. 関数名（intel471-alerts-collector など）をクリックします。
  6. [ログ] タブをクリックします。

  7. 関数が正常に実行されたことを確認します。以下のものを探します。

    Fetching alerts from YYYY-MM-DDTHH:MM:SS+00:00 to YYYY-MM-DDTHH:MM:SS+00:00
Page 1: Retrieved X alerts
Wrote X records to gs://bucket-name/intel471-alerts/alerts_YYYYMMDD_HHMMSS.ndjson
Successfully processed X records

  8. [Cloud Storage] > [バケット] に移動します。

  9. バケット名（intel471-watcher-alerts-logs など）をクリックします。

  10. 接頭辞フォルダ（intel471-alerts/ など）に移動します。

  11. 現在のタイムスタンプで新しい .ndjson ファイルが作成されたことを確認します。

ログにエラーが表示される場合:

  • HTTP 401: 環境変数で Intel 471 のメールアドレスと API キーを確認する
  • HTTP 403: アカウントに Watcher アラートの権限があることを確認する
  • HTTP 429: レート制限 - 関数はバックオフで自動的に再試行されます
  • 環境変数が不足している: 必要な変数がすべて設定されていることを確認します。

Google SecOps サービス アカウントを取得する

Google SecOps は、一意のサービス アカウントを使用して GCS バケットからデータを読み取ります。このサービス アカウントにバケットへのアクセス権を付与する必要があります。

サービス アカウントのメールアドレスを取得する

  1. [SIEM 設定] > [フィード] に移動します。
  2. [Add New Feed] をクリックします。
  3. [単一フィードを設定] をクリックします。
  4. [フィード名] フィールドに、フィードの名前を入力します（例: Intel 471 Watcher Alerts）。
  5. [ソースタイプ] として [Google Cloud Storage V2] を選択します。
  6. [ログタイプ] として [Intel 471 Watcher Alerts] を選択します。

  7. [サービス アカウントを取得する] をクリックします。一意のサービス アカウントのメールアドレスが表示されます。例:

    secops-12345678@secops-gcp-prod.iam.gserviceaccount.com

  8. このメールアドレスをコピーして、次のステップで使用します。

  9. [次へ] をクリックします。

  10. 次の入力パラメータの値を指定します。

    • ストレージ バケットの URL: 接頭辞パスを含む GCS バケット URI を入力します。

      gs://intel471-watcher-alerts-logs/intel471-alerts/

      次のように置き換えます。

      • intel471-watcher-alerts-logs: GCS バケット名。
      • intel471-alerts: アラートログが保存されているプレフィックス/フォルダパス。

    • Source deletion option: 必要に応じて削除オプションを選択します。

      • なし: 転送後にファイルを削除しません（テストに推奨）。
      • 転送されたファイルを削除する: 転送が完了した後にファイルを削除します。
      • 転送されたファイルと空のディレクトリを削除する: 転送が完了した後にファイルと空のディレクトリを削除します。

    • ファイルの最長存続期間: 過去数日間に変更されたファイルを含めます（デフォルトは 180 日）。

    • Asset namespace: アセットの名前空間。

    • Ingestion labels: このフィードのイベントに適用されるラベル

  11. [次へ] をクリックします。

  12. [Finalize] 画面で新しいフィードの設定を確認し、[送信] をクリックします。

Google SecOps サービス アカウントに IAM 権限を付与する

Google SecOps サービス アカウントには、GCS バケットに対する Storage オブジェクト閲覧者のロールが必要です。

  1. [Cloud Storage] > [バケット] に移動します。
  2. バケット名（intel471-watcher-alerts-logs など）をクリックします。
  3. [権限] タブに移動します。
  4. [アクセス権を付与] をクリックします。
  5. 次の構成情報を指定します。
    • プリンシパルを追加: Google SecOps サービス アカウントのメールアドレスを貼り付けます。
    • ロールを割り当てる: [Storage オブジェクト閲覧者] を選択します。
  6. [保存] をクリックします。

UDM マッピング テーブル

ログフィールド UDM マッピング ロジック
post.links.forum.uid additional.fields 標準の UDM フィールドでカバーされない追加のメタデータ フィールド
post.links.forum.name additional.fields
post.links.thread.uid additional.fields
post.links.thread.topic additional.fields
post.links.thread.count additional.fields
post.uid additional.fields
post.message additional.fields
highlight.field additional.fields
chunk.text additional.fields
chunk.hl additional.fields
actor.links.forumTotalCount additional.fields
actor.links.forumPrivateMessageTotalCount additional.fields
actor.links.instantMessageChannelTotalCount additional.fields
actor.links.reportTotalCount additional.fields
actor.links.instantMessageTotalCount additional.fields
actor.links.instantMessageServerTotalCount additional.fields
actor.links.forumPostTotalCount additional.fields
actor.lastUpdated additional.fields
actor.activeFrom additional.fields
actor.activeUntil additional.fields
data_leak_post.chunk_number additional.fields
data_leak_post.links.blog.uid additional.fields
data_leak_post.links.blog.name additional.fields
data_leak_post.links.thread.uid additional.fields
data_leak_post.links.thread.topic additional.fields
data_leak_post.links.thread.count additional.fields
data_leak_post.message additional.fields
actor.links.reports[].uid additional.fields
actor.links.reports[].admiraltyCode additional.fields
actor.links.reports[].dateOfInformation additional.fields
ステータス additional.fields
watcherUid additional.fields
watcherGroupUid additional.fields
report.uid additional.fields
report.admiraltyCode additional.fields
foundTime additional.fields
instantMessage.data.message.text additional.fields
instantMessage.data.message.uid additional.fields
instantMessage.data.channel.name additional.fields
instantMessage.data.channel.uid additional.fields
instantMessage.data.channel.url additional.fields
instantMessage.data.channel.registration_date additional.fields
instantMessage.data.channel.topic additional.fields
instantMessage.data.server.uid additional.fields
instantMessage.data.server.service_type additional.fields
post.links.forum.description metadata.description イベントまたはエンティティの説明
actor.links.reports[].subject metadata.description
report.subject metadata.description
report.released metadata.event_timestamp イベントのタイムスタンプ
metadata.event_type metadata.event_type イベントのタイプ（例: USER_LOGIN、NETWORK_CONNECTION）
uid metadata.product_log_id プロダクトのログ ID
data_leak_post.file_listing.download_url principal.url プリンシパルに関連付けられた URL
actor.links.reports[].portalReportUrl principal.url
report.portalReportUrl principal.url
post.links.authorActor.handle principal.user.attribute.labels ユーザー属性
actor.links.reports[].actorHandle principal.user.attribute.labels
instantMessage.data.actor.handle principal.user.attribute.labels
post.links.authorActor.uid principal.user.userid ユーザー ID
actor.uid principal.user.userid
data_leak_post.uid principal.user.userid
instantMessage.data.actor.uid principal.user.userid
report.uid event.idm.read_only_udm.metadata.additional.fields 変更履歴からマッピング
report.admiraltyCode event.idm.read_only_udm.metadata.additional.fields 変更履歴からマッピング
report.subject event.idm.read_only_udm.metadata.description 変更履歴からマッピング
report.portalReportUrl event.idm.read_only_udm.principal.url 変更履歴からマッピング
report.released event.idm.read_only_udm.metadata.event_timestamp 変更履歴からマッピング
post.links.forum.description" and "actor.links.reports.subject metadata.description 変更履歴からマッピング
post.links.authorActor.uid", "data_leak_post.uid" and "actor.uid principal.user.userid 変更履歴からマッピング
post.links.authorActor.handle" and "actor.links.reports.actorHandle principal.user.attribute.labels 変更履歴からマッピング
data_leak_post.file_listing.download_url" and "actor.links.reports.portalReportUrl principal.url 変更履歴からマッピング
post.links.forum.uid", "post.links.forum.name", "post.links.thread.uid", "post.links.thread.topic", "post.links.thread.count", "post.uid", "post.message", "highlights.field", "highlights.chunks.text", "highlights.chunks.hl", "actor.links.forumTotalCount", "actor.links.forumPrivateMessageTotalCount", "actor.links.instantMessageChannelTotalCount", "actor.links.reportTotalCount", "actor.links.instantMessageTotalCount", "actor.links.instantMessageServerTotalCount", "actor.links.forumPostTotalCount", "actor.lastUpdated", "actor.activeFrom", "actor.activeUntil", "data_leak_post.chunk_number", "data_leak_post.links.blog.uid", "data_leak_post.links.blog.name", "data_leak_post.links.thread.uid", "data_leak_post.links.thread.topic", "data_leak_post.links.thread.count", "data_leak_post.message", "actor.links.reports.uid", "actor.links.reports.admiraltyCode", "actor.links.reports.dateOfInformation additional.fields 変更履歴からマッピング

変更ログ

このパーサーの変更ログを表示する

さらにサポートが必要な場合 コミュニティ メンバーや Google SecOps のプロフェッショナルから回答を得ることができます。