容器计算服务 ACS：在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