Container Compute Service：在ACS叢集中建立Agent Sandbox

單擊左側導覽列自訂資源，選擇資源定義（CustomResourceDefinition）頁簽，單擊使用YAML建立資源。

使用以下YAML建立一個 SandboxSet 資源來向ack-sandbox-manager註冊一個名為code-interpreter的 E2B 模板。該模板基於 E2B 官方 code-interpreter 鏡像製作，用於執行 Python 代碼。

apiVersion: agents.kruise.io/v1alpha1
kind: SandboxSet
metadata:
  name: code-interpreter
  namespace: default
spec:
  scaleStrategy:
    maxUnavailable: 500
  replicas: 10  # 預熱池的大小，建議比預估的請求突發量略大
  template:
    # metadata:
      # annotations:
        # 可選， 不填則使用acs-profile中的安全性群組配置，
        # 需確保對應安全性群組有足夠的可用IP，至少需要大於replicas
        # IP不足會導致sandbox建立緩慢甚至失敗
        # network.alibabacloud.com/security-group-ids: sg-8******
      # labels:
        # 可選，用於在 ACK 叢集中將沙箱 Pod 調度到 ACS
        # alibabacloud.com/acs: "true"
    spec:
      initContainers:
        # 以 native-sidecar 形式聲明 agent-runtime，自動給沙箱容器注入 envd 等運行時組件
        - name: runtime
          image: registry-cn-hangzhou-vpc.ack.aliyuncs.com/acs/agent-runtime:v0.0.5
          command: [ "sh", "/workspace/entrypoint_inner.sh" ]
          volumeMounts:
            # 與主容器的共用目錄
            - name: envd-volume
              mountPath: /mnt/envd
          env:
            - name: ENVD_DIR
              value: /mnt/envd
            # 這個環境變數使得 sidecar 共用主容器的資源，不產生額外費用
            - name: __IGNORE_RESOURCE__
              value: "true"
          restartPolicy: Always
      containers:
      - name: sandbox
        # 官方維護的 e2b code-interpreter 鏡像，支援全地區、vpc 拉取
        image: registry-cn-hangzhou-vpc.ack.aliyuncs.com/acs/code-interpreter:v1.6
        imagePullPolicy: IfNotPresent
        # 推薦設定資源需求，否則在 ACS 環境下會被設定成超小規格影響運行
        resources:
          limits:
            cpu: 1
            memory: 1Gi
          requests:
            cpu: 1
            memory: 1Gi
        startupProbe:
          failureThreshold: 10
          httpGet:
            path: /health
            port: 49999
          initialDelaySeconds: 1
          periodSeconds: 2
          timeoutSeconds: 1
        env:
          # 指定 runtime 注入的 envd 組件位置
          - name: ENVD_DIR
            value: /mnt/envd
        volumeMounts:
          # 與 runtime 的共用目錄
          - name: envd-volume
            mountPath: /mnt/envd
        # 通過 post start hook 啟動 envd 服務
        lifecycle:
          postStart:
            exec:
              command: [ "/bin/bash", "-c", "/mnt/envd/envd-run.sh" ]
      # 保證容器快速銷毀，提高複用的機率
      terminationGracePeriodSeconds: 1
      volumes:
        - name: envd-volume
          emptyDir: { }

單擊左側導覽列容器組，選擇default命名空間，查看已經建立並預熱的code-interpreter沙箱環境Pod。

在本地環境中安裝Git和Python。

安裝E2B Python SDK。

pip install e2b-code-interpreter==2.4.1

配置環境變數。

# 使用安裝ack-sandbox-manager組件時預設的網域名稱，不需要帶*，可按實際配置修改
export E2B_DOMAIN=your.domain.com
# 使用安裝ack-sandbox-manager組件時預設的API Key，可按實際配置修改
export E2B_API_KEY=admin-987654321

執行git clone https://github.com/openkruise/agents.git命令，下載ACS定製SDK至本地。

進入本地定製SDK的/agents/sdk/customized_e2b目錄，將以下代碼儲存為main.py檔案。

# Import the E2B SDK
from e2b_code_interpreter import Sandbox
from kruise_agents.patch_e2b import patch_e2b

patch_e2b(https=False)  # patch sdk

sbx: Sandbox = Sandbox.create(template="code-interpreter")
print(f"sandbox id: {sbx.sandbox_id}")
result = sbx.run_code("print('hello, world')")
print(f"run code result: {result}")
text = input("enter some text to be saved to file 'text.txt' inside sandbox:  ")
sbx.files.write("text.txt", text)
print(f"read file from sandbox via files api: [{sbx.files.read('text.txt')}]")
print(f"read file from sandbox via commands api: [{sbx.commands.run('cat text.txt')}]")
input("press ENTER to kill the sandbox")
print(sbx.kill())

運行main.py檔案，建立並驗證沙箱環境。

在第一次出現提示後，輸入文字如acs agent sandbox，然後按ENTER鍵，會在名為code-interpreter-29***的Pod的/home/user/text.txt檔案中寫入acs agent sandbox；若再次按ENTER鍵，則會刪除當前沙箱環境。

python main.py

預期輸出：

sandbox id: default--code-interpreter-29***
run code result: Execution(Results: [], Logs: Logs(stdout: ['hello, world\n'], stderr: []), Error: None)
enter some text to be saved to file 'text.txt' inside sandbox:  acs agent sandbox
read file from sandbox via files api: [acs agent sandbox]
read file from sandbox via commands api: [CommandResult(stderr='', stdout='acs agent sandbox', exit_code=0, error='')]
press ENTER to kill the sandbox
True