Function Compute:File Storage NAS の動的マウント

コア機能

Function Compute の動的 NAS マウント機能を使用すると、セッションの作成時にセッション専用の NAS ディレクトリをマウントできます。必要に応じて、独立したユーザー ID (POSIX UID/GID) を指定することもできます。コア機能は次のとおりです。

• 動的かつオンデマンド: ストレージのマウントはセッションのライフサイクルに関連付けられています。ストレージは必要な場合にのみ割り当てられ、セッションが破棄されると自動的にデタッチされます。

• 強力な分離: 各セッションに一意のユーザー ID とグループ ID を割り当てることで、ファイルシステムレベルで異なるテナントのデータアクセス権限を完全に分離できます。

• 高い柔軟性: テナントごとに NAS ファイルシステムの異なるサブディレクトリをマウントできます。これにより、データパーティションが容易になります。

• パフォーマンスの最適化: セッションのプリフェッチと組み合わせることで、インスタンスの起動時にデータディレクトリを事前にマウントできます。これにより、モデルやデータの読み込みが高速化されます。

仕組み

この機能は、NAS マウント操作を CreateSession API 呼び出しと深く統合します。次のプロセスでは、HeaderField アフィニティを例として使用します。

ステップ 1: 関数の構成 (前提条件)

セッションの動的 NAS マウントを有効にするには、関数を作成するか、その構成を更新する際に、3 つの主要な設定を完了する必要があります。

1. セッション保持の有効化:

   1. Function Compute コンソールにログインし、[関数管理] > [関数リスト] に移動します。

   2. [関数リスト] ページで、関数名をクリックして関数の詳細ページに移動します。

   3. [設定] ページの [詳細設定] セクションで、 をクリックします。

   4. [セッション保持] スイッチをオンにし、[HeaderField アフィニティ] を選択し、[ヘッダー名] を x-affinity-header-v1 などの値で構成します。

      説明

      名前は x-fc- プレフィックスで始めることはできません。文字で始める必要があります。後続の文字には、数字、ハイフン (-)、アンダースコア (_)、または文字を使用できます。長さは 5 ～ 40 文字である必要があります。

   5. [デプロイ] をクリックして構成を適用します。

2. [インスタンスフェンシングの有効化]: [設定] > [詳細設定] > [インスタンスフェンシング] に移動し、[セッションフェンシング] を選択します。

3. VPC へのアクセスを許可

   • [設定] > [詳細設定] > [ネットワーク] に移動し、[VPC へのアクセスを許可] を有効にします。

   • [設定方法] で、[カスタム設定] を選択します。

   • [VPC] パラメーターで、マウントポイントを含む VPC を選択します。

ステップ 2: NAS 構成でセッションを作成する

1. 依存関係のインストール

   macOS / Linux

   # pip3 を使用してインストール
   pip3 install alibabacloud_fc20230330 alibabacloud_credentials alibabacloud_tea_openapi alibabacloud_tea_util
   
   # 権限の問題が発生した場合は、--user パラメーターを使用します
   pip3 install --user alibabacloud_fc20230330 alibabacloud_credentials alibabacloud_tea_openapi alibabacloud_tea_util
   
   # macOS Homebrew Python 環境の場合は、--break-system-packages を使用します
   pip3 install --break-system-packages alibabacloud_fc20230330 alibabacloud_credentials alibabacloud_tea_openapi alibabacloud_tea_util

   Windows

   # pip を使用してインストール
   pip install alibabacloud_fc20230330 alibabacloud_credentials alibabacloud_tea_openapi alibabacloud_tea_util
   
   # または、Python 3 を指定します
   py -3 -m pip install alibabacloud_fc20230330 alibabacloud_credentials alibabacloud_tea_openapi alibabacloud_tea_util

2. セッションを作成するコードを記述する

   Python コードファイル (例: createSession.py) を作成します。次のコードをファイルにコピーし、コアパラメーターを置き換えます。この例では、「テナント A」のセッションを作成する方法を示します。テナント専用の NAS ディレクトリ (<YOUR-NAS-SERVER-ADDR>:/tenant-a-data) をインスタンスの /mnt/data パスにマウントし、ユーザー ID を UID=1001 および GID=1001 として指定します。

   コアメソッドとパラメーター:

   重要

   セッションの動的 NAS マウントと、[設定] > [詳細設定] > [ストレージ] での関数の NAS マウントを同時に構成できます。ただし、次の点に注意してください。

   • 以下の NASConfig で定義された ユーザー ID/グループ ID は、関数マウント構成で使用されるユーザー (ユーザー ID)/ユーザーグループ (グループ ID) と一致している必要があります。

   • 同じマウントパス (mount_dir) をセッションの動的マウントと関数マウントの両方に使用することはできません。

   • config.endpoint:

     • <Account ID>: Alibaba Cloud アカウント ID に置き換えます。

     • <Endpoint>: 詳細については、「Function Compute 3.0 サービスエンドポイントのリスト」をご参照ください。フォーマットは fcv3.[region_id].aliyuns.com です。

   • CreateSessionInput:

     • session_ttlin_seconds: セッションの合計ライフサイクル (秒単位)。

     • session_idle_timeout_in_seconds: セッションのアイドルタイムアウト (秒単位)。

   • client.create_session_with_options: <Function Name> を、セッションを作成する関数の名前に置き換えます。

     • NASMountConfig: NAS マウント構成。

       • mount_dir: インスタンス内のマウントパス (例: /home/test)。

       • server_addr: NAS ファイルシステムのアドレスとテナント専用のサブディレクトリ。

     • user_id: このセッションに独立した POSIX ユーザー ID を指定します。

     • group_id: このセッションに独立した POSIX グループ ID を指定します。

   # -*- coding: utf-8 -*-
   from alibabacloud_fc20230330.client import Client as FC20230330Client
   from alibabacloud_credentials.client import Client as CredentialClient
   from alibabacloud_tea_openapi import models as open_api_models
   from alibabacloud_fc20230330 import models as fc20230330_models
   from alibabacloud_tea_util import models as util_models
   
   # 1. アカウントクライアントを作成します。
   credential = CredentialClient()
   config = open_api_models.Config(credential=credential)
   config.endpoint = f'<Account ID>.<Endpoint>'
   client = FC20230330Client(config)
   
   # 2. NAS マウント構成を準備します。
   nas_mount_config = fc20230330_models.NASMountConfig(
       mount_dir='/mnt/data',  # インスタンス内のマウントパス
       server_addr='<YOUR-NAS-SERVER-ADDR>:/<tenant-a-path>'  # NAS ファイルシステムのアドレスとテナント専用のサブディレクトリ
   )
   
   # 3. NAS とユーザー ID を構成します (テナント A に一意の UID/GID を割り当てます)。
   nas_config = fc20230330_models.NASConfig(
       mount_points=[nas_mount_config],
       user_id=1001,  # このセッションに独立した POSIX ユーザー ID を指定します。
       group_id=1001  # このセッションに独立した POSIX グループ ID を指定します。
   )
   
   # 4. CreateSession リクエストを構築します。
   create_session_input = fc20230330_models.CreateSessionInput(
       nas_config=nas_config,
       session_ttlin_seconds=3600,
       session_idle_timeout_in_seconds=600
   )
   create_session_request = fc20230330_models.CreateSessionRequest(
       body=create_session_input
   )
   
   # 5. リクエストを送信します。
   runtime = util_models.RuntimeOptions()
   response = client.create_session_with_options('<Function Name>', create_session_request, {}, runtime)
   
   # 6. レスポンスからセッション ID を取得します。
   print(response.body.to_map())
   session_id = response.body.session_id
   print(f"セッションが正常に作成されました。セッション ID: {session_id}")
   

3. コードの実行

   export ALIBABA_CLOUD_ACCESS_KEY_ID=LTAI****************
   export ALIBABA_CLOUD_ACCESS_KEY_SECRET=<yourAccessKeySecret>
   python3 creatSession.py

   パラメーター:

   • ALIBABA_CLOUD_ACCESS_KEY_ID: Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID。

   • ALIBABA_CLOUD_ACCESS_KEY_SECRET: Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey Secret。

4. レスポンスの例

   {
     'containerId': 'c-********-********-************', 
     'createdTime': '2025-10-30T06:38:10Z', 
     'functionName': '****', 
     'lastModifiedTime': '2025-10-30T06:38:10Z', 
     'nasConfig': 
       {
         'groupId': 1001, 
         'mountPoints': [
           {
             'enableTLS': False, 
             'mountDir': '/home/test', 
             'serverAddr': '*-*.*.nas.aliyuncs.com:/test'
              }
                ], 
                'userId': 1001
                }, 
      'qualifier': 'LATEST', 
      'sessionAffinityType': 'HEADER_FIELD', 
      'sessionId': '******************', 
      'sessionIdleTimeoutInSeconds': 600, 
      'sessionStatus': 'Active', 
      'sessionTTLInSeconds': 3600
      }
   セッションが正常に作成されました。セッション ID: ************

ステップ 3: 関数でマウントされた NAS を使用する

これで、関数を呼び出すときに、前のステップで取得した SessionID を含めることができます。関数インスタンスは、マウントされた /mnt/data ディレクトリにアクセスできます。次の例では、Web 関数を使用します。

1. 関数コードを変更して再デプロイします。

   import os
   from flask import Flask, request, jsonify
   
   # ... (アプリのセットアップ) ...
   
   # NAS マウントポイントが /mnt/data にあると仮定します
   NAS_MOUNT_PATH = '/mnt/data'
   app = Flask(__name__)
   
   
   @app.route('/<path:path>', methods=['GET', 'POST'])
   def handle_nas_request(path):
       rid = request.headers.get('x-fc-request-id')
       print(f"FC 呼び出し開始 RequestId: {rid}")
   
       # NAS 上のファイルの完全なパスを構築します
       # 注: パストラバーサル攻撃を防止します
       safe_path = os.path.normpath(os.path.join(NAS_MOUNT_PATH, path))
       if not safe_path.startswith(NAS_MOUNT_PATH):
           return "パストラバーサルの試みが検出されました!", 400
   
       response_data = {}
   
       if request.method == 'POST':
           # ファイルに書き込みます
           body = request.data.decode('utf-8')
           try:
               with open(safe_path, 'w') as f:
                   f.write(body)
               response_data['message'] = f"{safe_path} への書き込みに成功しました"
               print(f"{safe_path} に書き込みました")
           except Exception as e:
               return str(e), 500
   
       elif request.method == 'GET':
           # ファイルから読み取ります
           try:
               if os.path.exists(safe_path) and os.path.isfile(safe_path):
                   with open(safe_path, 'r') as f:
                       content = f.read()
                   response_data['content'] = content
                   print(f"{safe_path} から読み取りました")
               else:
                   return f"ファイルが見つかりません: {safe_path}", 404
           except Exception as e:
               return str(e), 500
   
       print(f"FC 呼び出し終了 RequestId: {rid}")
       return jsonify(response_data)  # jsonify を使用して JSON 形式でレスポンスを返します
   
   # ... (if __name__ == '__main__': ブロック) ...
   

2. 関数を呼び出して結果を確認します。

   InvokeFunction API を呼び出して、セッション付きで関数を呼び出します。

   サンプルコードと説明:

   InvokeFunctionHeaders: リクエストヘッダーを構築します。前のステップで返された sessionId をリクエストヘッダーに含めます。ヘッダーキーの値は、セッション保持を有効にしたときに設定した値 (例: x-affinity-header-v1) と同じである必要があります。これにより、ルーティングのためにセッションがバインドされます。

   # -*- coding: utf-8 -*-
   from alibabacloud_fc20230330.client import Client as FC20230330Client
   from alibabacloud_credentials.client import Client as CredentialClient
   from alibabacloud_tea_openapi import models as open_api_models
   from alibabacloud_fc20230330 import models as fc20230330_models
   from alibabacloud_tea_util import models as util_models
   
   session_id = '************'
   function_name = 'my-session-nas'
   # 1. アカウントクライアントを作成します。
   credential = CredentialClient()
   config = open_api_models.Config(credential=credential)
   config.endpoint = f'<Account ID>.<Endpoint>'
   client = FC20230330Client(config)
   
   # 2. リクエストヘッダーを構築します。ヘッダーキー (x-affinity-header-v1) は、関数に構成されたセッション保持キーと一致する必要があります。
   headers = fc20230330_models.InvokeFunctionHeaders(
       common_headers={
           "x-affinity-header-v1": session_id
       }
   )
   
   # 3. 呼び出しリクエストを構築します (必要に応じて本文を渡すことができます)。
   invoke_request = fc20230330_models.InvokeFunctionRequest(
       body='your_request_payload'.encode('utf-8')  # サンプルペイロード
   )
   
   runtime = util_models.RuntimeOptions()
   
   try:
       # 4. 呼び出しを送信します。
       invoke_response = client.invoke_function_with_options(
           function_name,
           invoke_request,
           headers,
           runtime
       )
       # 5. レスポンスを処理します。
       print(f"ステータスコード: {invoke_response.status_code}")
       print(f"レスポンス本文: {invoke_response.body.decode('utf-8')}")
   except Exception as error:
       print(error.message)