Menlo Security Isolation Platform（MSIP）のログを収集する

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

Google SecOps SIEM

このガイドでは、Google Cloud Storage を使用して Menlo Security Isolation Platform（MSIP）ログを Google SecOps に取り込む方法について説明します。

Menlo Security の分離中心のアプローチでは、ウェブ ブラウジングとドキュメント取得をユーザーのデバイスと、エンドポイントから離れた隔離された使い捨て仮想コンテナ（DVC）に分割します。リスクのあるコードはすべて分離された DVC で実行され、エンドポイントに到達することはありません。安全な表示データのみがユーザーのブラウザに送信されます。このプラットフォームは、ウェブアクセス、監査イベント、メール セキュリティ、DLP 違反、SMTP アクティビティに関する包括的なロギングを提供します。

始める前に

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

• Google SecOps インスタンス
• Menlo Security 管理ポータルへの特権アクセス
• Menlo Security で API トークンを作成する権限
• Cloud Storage、Cloud Run、Pub/Sub、Cloud Scheduler API が有効になっている GCP プロジェクト

Menlo Security API アクセスを構成する

Cloud Run 関数がログを取得できるようにするには、ログ エクスポート API 権限を持つ API トークンを作成する必要があります。

API トークンを作成する

1. https://admin.menlosecurity.com で Menlo Security 管理ポータルにログインします。
2. [設定] > [認証] > [API トークン] に移動します。
3. [トークンの作成] をクリックします。
4. [トークン名] フィールドに、わかりやすい名前（Chronicle GCS Integration など）を入力します。
5. [権限] セクションで、[ログ エクスポート API] を選択します。
6. [作成] または [保存] をクリックします。
7. 生成された API トークンをコピーして安全に保存します。

重要: API トークンは 1 回しか表示されません。作成したらすぐに安全な場所に保管します。

必要な API 権限

• API トークンには次の権限が必要です。

  権限/スコープ	アクセスレベル	目的
  Log Export API	読み取り	Menlo Security API からログを取得する

  注: ログの取り込みに必要なのは、ログ エクスポート API 権限のみです。追加の権限は必要ありません。

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

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

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

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

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

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

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

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

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

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

Pub/Sub トピックの作成

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

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

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

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

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

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

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

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

   1. [認証が必要] を選択します。
   2. Identity and Access Management（IAM）を確認します。
   注: Pub/Sub は、関数を呼び出すときに認証を自動的に処理します。

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

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

   • サービス アカウント: menlo-logs-collector-sa を選択します。

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

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

   変数名	値の例	説明
   GCS_BUCKET	menlo-security-logs	GCS バケット名
   GCS_PREFIX	menlo-logs	ログファイルの接頭辞
   STATE_KEY	menlo-logs/state.json	状態ファイルのパス
   MENLO_API_TOKEN	your-menlo-api-token	Menlo Security API トークン
   MENLO_API_HOST	logs.menlosecurity.com	Menlo Security API ホスト
   MENLO_LOG_TYPES	web,audit,email,dlp	カンマ区切りのログタイプ
   LOOKBACK_HOURS	1	初期ルックバック期間

   注: MENLO_LOG_TYPES 変数には、収集するログタイプのカンマ区切りのリストを指定します。サポートされている値は、web、audit、email、dlp、attachment、smtp です。

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

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

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

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

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

    • インスタンスの最小数: 0 と入力します。
    • [インスタンスの最大数] に「100」と入力します。

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

14. サービスが作成されるまで待ちます（1 ～ 2 分）。

15. サービスを作成すると、インライン コードエディタが自動的に開きます。

関数コードを追加する

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

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

   • main.py:

   import functions_framework
   from google.cloud import storage
   import os
   import json
   import urllib3
   import time
   import uuid
   from datetime import datetime, timezone, timedelta
   
   http = urllib3.PoolManager(
     timeout=urllib3.Timeout(connect=5.0, read=60.0),
     retries=False,
   )
   
   storage_client = storage.Client()
   
   GCS_BUCKET = os.environ.get('GCS_BUCKET')
   GCS_PREFIX = os.environ.get('GCS_PREFIX', 'menlo-logs')
   STATE_KEY = os.environ.get('STATE_KEY', 'menlo-logs/state.json')
   API_TOKEN = os.environ.get('MENLO_API_TOKEN')
   API_HOST = os.environ.get('MENLO_API_HOST', 'logs.menlosecurity.com')
   LOG_TYPES = os.environ.get('MENLO_LOG_TYPES', 'web').split(',')
   LOOKBACK_HOURS = int(os.environ.get('LOOKBACK_HOURS', '1'))
   
   @functions_framework.cloud_event
   def main(cloud_event):
     if not all([GCS_BUCKET, API_TOKEN, API_HOST]):
       print('Error: Missing required environment variables')
       return
   
     try:
       bucket = storage_client.bucket(GCS_BUCKET)
       state = load_state(bucket)
       now = datetime.now(timezone.utc).replace(microsecond=0)
   
       if isinstance(state, dict) and state.get('last_event_time'):
         try:
           last_val = state['last_event_time']
           if last_val.endswith('Z'):
             last_val = last_val[:-1] + '+00:00'
           last_time = datetime.fromisoformat(last_val)
           last_time = last_time - timedelta(minutes=2)
         except Exception as e:
           print(f"Warning: Could not parse last_event_time: {e}")
           last_time = now - timedelta(hours=LOOKBACK_HOURS)
       else:
         last_time = now - timedelta(hours=LOOKBACK_HOURS)
   
       print(f"Fetching logs from {last_time.isoformat()} to {now.isoformat()}")
   
       total = 0
       newest_time = None
   
       for log_type in LOG_TYPES:
         log_type = log_type.strip()
         print(f"Fetching {log_type} logs...")
         events = fetch_logs(log_type, API_TOKEN, API_HOST, last_time, now)
   
         if events:
           object_key = f"{GCS_PREFIX}/{now:%Y/%m/%d}/menlo-{log_type}-{uuid.uuid4()}.ndjson"
           blob = bucket.blob(object_key)
   
           ndjson = '\n'.join(
             [json.dumps(ev, ensure_ascii=False) for ev in events]
           ) + '\n'
           blob.upload_from_string(ndjson, content_type='application/x-ndjson')
   
           print(f"Uploaded {len(events)} {log_type} events to gs://{GCS_BUCKET}/{object_key}")
           total += len(events)
   
           for ev in events:
             ev_time = ev.get('timestamp') or ev.get('time') or ev.get('created_at')
             if ev_time and (newest_time is None or str(ev_time) > str(newest_time)):
               newest_time = str(ev_time)
         else:
           print(f"No {log_type} events found")
   
       save_state(bucket, newest_time if newest_time else now.isoformat())
       print(f"Successfully processed {total} total events")
   
     except Exception as e:
       print(f'Error processing logs: {str(e)}')
       raise
   
   def fetch_logs(log_type, token, api_host, start, end):
     url = f"https://{api_host}/api/v1/logs/{log_type}"
     headers = {
       'Authorization': f'Token {token}',
       'Accept': 'application/json',
     }
     params = {
       'start': start.strftime('%Y-%m-%dT%H:%M:%SZ'),
       'end': end.strftime('%Y-%m-%dT%H:%M:%SZ'),
     }
     query = '&'.join(f'{k}={v}' for k, v in params.items())
     full_url = f'{url}?{query}'
   
     all_events = []
     backoff = 1.0
   
     while full_url:
       response = http.request('GET', full_url, headers=headers)
   
       if response.status == 429:
         retry_after = int(response.headers.get('Retry-After', str(int(backoff))))
         print(f"Rate limited. Waiting {retry_after}s...")
         time.sleep(retry_after)
         backoff = min(backoff * 2, 60.0)
         continue
   
       if response.status != 200:
         print(f"API error {response.status}: {response.data.decode('utf-8')}")
         break
   
       backoff = 1.0
       data = json.loads(response.data.decode('utf-8'))
       events = data if isinstance(data, list) else data.get('events', data.get('data', []))
       all_events.extend(events)
   
       full_url = data.get('next') if isinstance(data, dict) else None
   
     print(f"Total {log_type} events fetched: {len(all_events)}")
     return all_events
   
   def load_state(bucket):
     try:
       blob = bucket.blob(STATE_KEY)
       if blob.exists():
         return json.loads(blob.download_as_text())
     except Exception as e:
       print(f"Warning: Could not load state: {e}")
     return {}
   
   def save_state(bucket, last_event_time_iso):
     try:
       state = {
         'last_event_time': last_event_time_iso,
         'last_run': datetime.now(timezone.utc).isoformat()
       }
       blob = bucket.blob(STATE_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}")
   

   • requirements.txt:

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

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

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

   注: Pub/Sub トリガー構成では、必要なサブスクリプションと権限が自動的に作成されます。

Cloud Scheduler ジョブの作成

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

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

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

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

統合をテストする

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

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

   Fetching logs from YYYY-MM-DDTHH:MM:SS+00:00 to YYYY-MM-DDTHH:MM:SS+00:00
   Fetching web logs...
   Total web events fetched: X
   Uploaded X web events to gs://menlo-security-logs/menlo-logs/YYYY/MM/DD/menlo-web-UUID.ndjson
   Successfully processed X total events
   

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

9. menlo-security-logs をクリックします。

10. menlo-logs/ フォルダに移動します。

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

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

• HTTP 401: MENLO_API_TOKEN 環境変数が正しいことを確認する
• HTTP 403: API トークンに Log Export API 権限があることを確認します。
• HTTP 429: レート制限 - 関数はバックオフで自動的に再試行されます
• 環境変数がありません: 必要な変数がすべて Cloud Run functions の構成で設定されていることを確認します。

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

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

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

   [e-mail]
   

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

   注: 各 Google SecOps インスタンスには一意のサービス アカウントがあります。他のドキュメントや例のサービス アカウントは使用しないでください。

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

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

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

      gs://menlo-security-logs/menlo-logs/
      

    注: URI の末尾には常にスラッシュ（/）を含めてください。

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

      • なし: 転送後にファイルを削除しません（テストにおすすめ）。
      • 転送されたファイルを削除する: 転送が完了した後にファイルを削除します。

      • 転送されたファイルと空のディレクトリを削除する: 転送が完了した後にファイルと空のディレクトリを削除します。

        注: 削除オプションを選択する場合は、サービス アカウントに Storage オブジェクト閲覧者ではなく、Storage オブジェクト管理者のロールが必要です。必要に応じて IAM 権限を更新します。

      • ファイルの最大経過日数: 過去の日数以内に変更されたファイルを含めます（デフォルトは 180 日）。

      • アセットの名前空間: アセットの名前空間

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

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

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

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

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

注: 削除オプションの [転送されたファイルを削除] または [転送されたファイルと空のディレクトリを削除] を使用する場合は、Storage オブジェクト閲覧者ではなく、Storage オブジェクト管理者ロールを付与します。

UDM マッピング テーブル

ログフィールド	UDM マッピング	ロジック
customer_name	intermediary.hostname	customer_name が IP でない場合に設定
customer_name	intermediary.ip	IP の場合は customer_name から、xff_ip IP の場合は xff_ip から抽出されます
xff_ip	intermediary.ip
event_data.event_time	metadata.event_timestamp	grok と日付フィルタを使用して解析
request_type	metadata.event_type	これらのフィールドに基づく条件付きロジック
has_principal	metadata.event_type
has_top_url	metadata.event_type
has_dest	metadata.event_type
log_type	metadata.log_type	値を直接コピーする
event_data.name	metadata.product_event_type	値を直接コピーする
reqId	metadata.product_log_id	値を直接コピーする
event_data.version	metadata.product_version	値を直接コピーする
event_data.protocol	network.application_protocol	事前定義されたプロトコル リストを使用してマッピング
request_type	network.http.method	値を直接コピーする
リファラー	network.http.referral_url	値を直接コピーする
response_code	network.http.response_code	整数に変換しました
event_data.user-agent	network.http.user_agent	値を直接コピーする
full_session_id	network.session_id	値を直接コピーする
browser_and_version	principal.application	値を直接コピーする
event_data.x-client-ip	principal.asset.ip	event_data.x-client-ip の値（空でない場合）。空の場合は src_ip
src_ip	principal.asset.ip
グループ	principal.group.product_object_id	値を直接コピーする
event_data.x-client-ip	principal.ip	event_data.x-client-ip の値（空でない場合）。空の場合は src_ip
src_ip	principal.ip
region	principal.location.country_or_region	空でない場合はリージョンからの値、それ以外の場合は egress_country
egress_country	principal.location.country_or_region
region_name	principal.location.name	値を直接コピーする
egress_ip	principal.nat_ip	値を直接コピーする
event_data.userid	principal.user.email_addresses	メールの正規表現に一致する場合に統合
event_data.userid	principal.user.userid	値を直接コピーする
event_data.domain	security_result.about.administrative_domain	値を直接コピーする
event_data.url	security_result.about.url	値を直接コピーする
event_data.pe_action	security_result.action	ALLOW、BLOCK、ALLOW_WITH_MODIFICATION にマッピングされます
event_data.categories	security_result.category_details	event_data.categories（抽出または直接）と casb_cat_name から統合
casb_cat_name	security_result.category_details
event_data.risk_score	security_result.confidence_details	値を直接コピーする
content-type	security_result.detection_fields	さまざまなラベル フィールドから統合
product	security_result.detection_fields
脅威	security_result.detection_fields
virusDetails	security_result.detection_fields
sandboxResult	security_result.detection_fields
fullScanResult	security_result.detection_fields
tab_id	security_result.detection_fields
pe_reason	security_result.detection_fields
ua_type	security_result.detection_fields
email_isolation_state	security_result.detection_fields
document_url	security_result.detection_fields
archive_path	security_result.detection_fields
casb_app_name	security_result.detection_fields
casb_fun_name	security_result.detection_fields
casb_org_name	security_result.detection_fields
casb_profile_id	security_result.detection_fields
casb_profile_name	security_result.detection_fields
casb_profile_type	security_result.detection_fields
casb_risk_score	security_result.detection_fields
connId	security_result.detection_fields
origin_country	security_result.detection_fields
egress_country	security_result.detection_fields
is_casb_ddl	security_result.detection_fields
is_iframe	security_result.detection_fields
parent_file_id	security_result.detection_fields
parent_filename	security_result.detection_fields
parent_sha256	security_result.detection_fields
parent_tid	security_result.detection_fields
root_file_id	security_result.detection_fields
root_filename	security_result.detection_fields
root_sha256	security_result.detection_fields
casb_risk_score	security_result.risk_score	浮動小数点数に変換済み
casb_profile_id	security_result.rule_id	値を直接コピーする
pe_rulename	security_result.rule_name	値を直接コピーする
casb_profile_name	security_result.rule_set	値を直接コピーする
casb_profile_type	security_result.rule_type	値を直接コピーする
event_data.severity	security_result.severity_details	値を直接コピーする
magicName	security_result.summary	「%{magicName} は %{threats} です。」と連結されます。
脅威	security_result.summary
threat_types	security_result.threat_name	値を直接コピーする
origin_ip	src_ip	値を直接コピーする
origin_country	src.location.country_or_region	値を直接コピーする
event_data.dst	target.asset.ip	grok IP パターンを使用して event_data.dst または dst から抽出されます
dst	target.asset.ip
filename	target.file.full_path	値を直接コピーする
mimeType	target.file.mime_type	値を直接コピーする
sha256	target.file.sha256	値を直接コピーする
file_size	target.file.size	浮動小数点数に変換してから符号なし整数に変換
event_data.dst	target.ip	grok IP パターンを使用して event_data.dst または dst から抽出されます
dst	target.ip
top_url	target.url	URI grok パターンを使用して抽出
metadata.product_name	metadata.product_name	「MENLO SECURITY」に設定
metadata.vendor_name	metadata.vendor_name	「MENLO SECURITY」に設定
region	event.idm.read_only_udm.principal.location.country_or_region	変更履歴からマッピング
region_name	event.idm.read_only_udm.principal.location.name	変更履歴からマッピング
src_ip	event.idm.read_only_udm.principal.ip と event.idm.read_only_udm.principal.asset.ip	変更履歴からマッピング
groups	event.idm.read_only_udm.principal.group.product_object_id	変更履歴からマッピング
content-type	event.idm.read_only_udm.security_result.detection_fields	変更履歴からマッピング
product	event.idm.read_only_udm.security_result.detection_fields	変更履歴からマッピング
mimeType	event.idm.read_only_udm.target.file.mime_type	変更履歴からマッピング

変更ログ

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

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