Kimi Code

Обновление образов

Готовые образы агентов обновляются каждое утро и содержат актуальную версию CLI. Чтобы использовать фиксированную версию образа, закрепите версию шаблона.

Kimi Code — агент Moonshot AI с инструментами чтения и записи файлов, выполнения команд и поиска. Используйте шаблон kimi, чтобы запустить официальный CLI в отдельной песочнице и получить результат из приложения.

Подключение

Установите SDK AgentBox и задайте AGENTBOX_API_KEY.

В примерах модель moonshotai/kimi-k2.5 вызывается через OpenRouter. Приложение читает OPENROUTER_API_KEY и передаёт его CLI в KIMI_MODEL_API_KEY. Переменные KIMI_MODEL_PROVIDER_TYPE, KIMI_MODEL_BASE_URL и KIMI_MODEL_NAME выбирают OpenAI-совместимый протокол, адрес OpenRouter и модель. Эти настройки действуют для запуска процесса и не требуют интерактивного входа.

Для доступа к модели можно использовать HTTPS-прокси AgentBox https://sandbox-proxy.agentbox.ru:65181.

В примерах HTTPS_PROXY, HTTP_PROXY и NO_PROXY передаются процессу агента. Эти настройки могут влиять и на другие запросы агента и его дочерних процессов. Соединения с localhost и 127.0.0.1 остаются прямыми.

Подготовьте ответ клиенту

Пример передаёт сведения о заказе и просит Kimi записать черновик ответа в reply.md. Приложение получает готовый файл через SDK файловой системы.

mjs

import { Sandbox } from "@abox-dev/sdk";

const apiKey = process.env.OPENROUTER_API_KEY;
if (!apiKey) throw new Error("OPENROUTER_API_KEY is required");
const proxy =
  process.env.SANDBOX_PROXY_URL ?? "https://sandbox-proxy.agentbox.ru:65181";
const sandbox = await Sandbox.create("kimi", { timeoutMs: 600_000 });
try {
  await sandbox.files.makeDir("/home/user/work");
  await sandbox.files.write(
    "/home/user/work/request.txt",
    "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n",
  );
  const result = await sandbox.commands.run('kimi -p "$AGENT_PROMPT"', {
    cwd: "/home/user/work",
    timeoutMs: 300_000,
    envs: {
      HTTPS_PROXY: proxy,
      HTTP_PROXY: proxy,
      NO_PROXY: "localhost,127.0.0.1",
      AGENT_PROMPT:
        "Read request.txt and write reply.md with a short response to the customer.",
      KIMI_MODEL_API_KEY: apiKey,
      KIMI_MODEL_PROVIDER_TYPE: "openai",
      KIMI_MODEL_BASE_URL: "https://openrouter.ai/api/v1",
      KIMI_MODEL_NAME: "moonshotai/kimi-k2.5",
      KIMI_MODEL_MAX_CONTEXT_SIZE: "262144",
      KIMI_MODEL_CAPABILITIES: "tool_use",
    },
    onStderr: (chunk) => process.stderr.write(chunk),
  });
  console.log(result.stdout);
  console.log(
    "reply.md\n" + (await sandbox.files.read("/home/user/work/reply.md")),
  );
} finally {
  await sandbox.kill();
}

import os
import sys
from agentbox import Sandbox

api_key = os.environ["OPENROUTER_API_KEY"]
proxy = os.getenv("SANDBOX_PROXY_URL", "https://sandbox-proxy.agentbox.ru:65181")
sandbox = Sandbox.create("kimi", timeout=600)
try:
    sandbox.files.make_dir("/home/user/work")
    sandbox.files.write(
        "/home/user/work/request.txt",
        "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n",
    )
    result = sandbox.commands.run(
        'kimi -p "$AGENT_PROMPT"',
        cwd="/home/user/work",
        timeout=300,
        envs={
            "HTTPS_PROXY": proxy,
            "HTTP_PROXY": proxy,
            "NO_PROXY": "localhost,127.0.0.1",
            "AGENT_PROMPT": "Read request.txt and write reply.md with a short response to the customer.",
            "KIMI_MODEL_API_KEY": api_key,
            "KIMI_MODEL_PROVIDER_TYPE": "openai",
            "KIMI_MODEL_BASE_URL": "https://openrouter.ai/api/v1",
            "KIMI_MODEL_NAME": "moonshotai/kimi-k2.5",
            "KIMI_MODEL_MAX_CONTEXT_SIZE": "262144",
            "KIMI_MODEL_CAPABILITIES": "tool_use",
        },
        on_stderr=lambda chunk: print(chunk, end="", file=sys.stderr),
    )
    print(result.stdout)
    print("reply.md\n" + sandbox.files.read("/home/user/work/reply.md"))
finally:
    sandbox.kill()

package main

import (
	"context"
	"errors"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/abox-dev/sdk/packages/go-sdk"
)

func run() (err error) {
	apiKey := os.Getenv("OPENROUTER_API_KEY")
	if apiKey == "" {
		return errors.New("OPENROUTER_API_KEY is required")
	}
	proxy := os.Getenv("SANDBOX_PROXY_URL")
	if proxy == "" {
		proxy = "https://sandbox-proxy.agentbox.ru:65181"
	}
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
	defer cancel()
	client, err := agentbox.NewClient()
	if err != nil {
		return err
	}
	sandbox, err := client.Sandboxes.Create(ctx, &agentbox.CreateSandboxOptions{Template: "kimi", Timeout: 10 * time.Minute})
	if err != nil {
		return err
	}
	defer func() {
		cleanupCtx, stop := context.WithTimeout(context.Background(), 30*time.Second)
		defer stop()
		_, cleanupErr := sandbox.Kill(cleanupCtx)
		err = errors.Join(err, cleanupErr)
	}()
	if _, err := sandbox.Files.MakeDir(ctx, "/home/user/work"); err != nil {
		return err
	}
	if _, err := sandbox.Files.WriteText(ctx, "/home/user/work/request.txt", "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n", nil); err != nil {
		return err
	}
	result, err := sandbox.Commands.Run(ctx, "sh", &agentbox.CommandOptions{
		Args: []string{"-lc", "kimi -p \"$AGENT_PROMPT\""},
		Cwd:  "/home/user/work",
		Env: map[string]string{
			"HTTPS_PROXY":                 proxy,
			"HTTP_PROXY":                  proxy,
			"NO_PROXY":                    "localhost,127.0.0.1",
			"AGENT_PROMPT":                "Read request.txt and write reply.md with a short response to the customer.",
			"KIMI_MODEL_API_KEY":          apiKey,
			"KIMI_MODEL_PROVIDER_TYPE":    "openai",
			"KIMI_MODEL_BASE_URL":         "https://openrouter.ai/api/v1",
			"KIMI_MODEL_NAME":             "moonshotai/kimi-k2.5",
			"KIMI_MODEL_MAX_CONTEXT_SIZE": "262144",
			"KIMI_MODEL_CAPABILITIES":     "tool_use",
		},
		OnStderr: func(chunk []byte) { fmt.Fprint(os.Stderr, string(chunk)) },
	})
	if err != nil {
		return err
	}
	fmt.Println(string(result.Stdout))
	report, err := sandbox.Files.ReadText(ctx, "/home/user/work/reply.md", "")
	if err != nil {
		return err
	}
	fmt.Println("reply.md\n" + report)
	return nil
}

func main() {
	if err := run(); err != nil {
		log.Fatal(err)
	}
}

-p выполняет задание без интерактивного интерфейса. В этом режиме обычные инструменты автоматически работают без запросов подтверждения, отдельные флаги --auto или --yolo не нужны. Текст задания передаётся через переменную окружения и раскрывается в кавычках, поэтому shell сохраняет его как один аргумент.

Пример читает результат до удаления песочницы. finally освобождает её и при ошибке. В Go для очистки используется отдельный контекст.

События и продолжение сессии

--output-format stream-json возвращает сообщения в JSONL. Пример показывает ответы и названия инструментов, получает ID сессии и передаёт уточнение по доставке в ту же сессию.

mjs

import { Sandbox } from "@abox-dev/sdk";

const apiKey = process.env.OPENROUTER_API_KEY;
if (!apiKey) throw new Error("OPENROUTER_API_KEY is required");
const proxy =
  process.env.SANDBOX_PROXY_URL ?? "https://sandbox-proxy.agentbox.ru:65181";
const sandbox = await Sandbox.create("kimi", { timeoutMs: 600_000 });
try {
  await sandbox.files.makeDir("/home/user/work");
  await sandbox.files.write(
    "/home/user/work/request.txt",
    "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n",
  );
  async function execute(prompt, sessionId) {
    let pending = "",
      nextSessionId;
    function event(message) {
      if (message.role === "assistant") {
        if (message.content) console.log(message.content);
        for (const call of message.tool_calls ?? [])
          console.log("Tool:", call.function.name);
      }
      if (message.type === "session.resume_hint")
        nextSessionId = message.session_id;
    }
    function onStdout(chunk) {
      pending += chunk;
      let newline;
      while ((newline = pending.indexOf("\n")) !== -1) {
        const line = pending.slice(0, newline);
        pending = pending.slice(newline + 1);
        if (line.trim()) event(JSON.parse(line));
      }
    }
    await sandbox.commands.run(
      'kimi -p "$AGENT_PROMPT" --output-format stream-json' +
        (sessionId ? ' --session "$AGENT_SESSION_ID"' : ""),
      {
        cwd: "/home/user/work",
        timeoutMs: 300_000,
        envs: {
          HTTPS_PROXY: proxy,
          HTTP_PROXY: proxy,
          NO_PROXY: "localhost,127.0.0.1",
          AGENT_PROMPT: prompt,
          KIMI_MODEL_API_KEY: apiKey,
          KIMI_MODEL_PROVIDER_TYPE: "openai",
          KIMI_MODEL_BASE_URL: "https://openrouter.ai/api/v1",
          KIMI_MODEL_NAME: "moonshotai/kimi-k2.5",
          KIMI_MODEL_MAX_CONTEXT_SIZE: "262144",
          KIMI_MODEL_CAPABILITIES: "tool_use",
          AGENT_SESSION_ID: sessionId ?? "",
        },
        onStdout,
        onStderr: (chunk) => process.stderr.write(chunk),
      },
    );
    if (pending.trim()) event(JSON.parse(pending));
    if (!nextSessionId) throw new Error("Agent did not return a session ID");
    console.log("\nSession:", nextSessionId);
    return nextSessionId;
  }
  const sessionId = await execute(
    "Read request.txt and write reply.md with a short response to the customer.",
  );
  await execute(
    "Logistics has confirmed delivery on September 22, 2026 instead. Update reply.md with the new date.",
    sessionId,
  );
  console.log(
    "reply.md\n" + (await sandbox.files.read("/home/user/work/reply.md")),
  );
} finally {
  await sandbox.kill();
}

import json
import os
import sys
from agentbox import Sandbox

api_key = os.environ["OPENROUTER_API_KEY"]
proxy = os.getenv("SANDBOX_PROXY_URL", "https://sandbox-proxy.agentbox.ru:65181")
sandbox = Sandbox.create("kimi", timeout=600)
try:
    sandbox.files.make_dir("/home/user/work")
    sandbox.files.write(
        "/home/user/work/request.txt",
        "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n",
    )

    def execute(prompt, session_id=None):
        pending = ""
        next_session_id = None

        def event(message):
            nonlocal next_session_id
            if message.get("role") == "assistant":
                if message.get("content"):
                    print(message["content"])
                for call in message.get("tool_calls", []):
                    print("Tool:", call["function"]["name"])
            if message.get("type") == "session.resume_hint":
                next_session_id = message.get("session_id")

        def on_stdout(chunk):
            nonlocal pending
            pending += chunk
            while "\n" in pending:
                line, pending = pending.split("\n", 1)
                if line.strip():
                    event(json.loads(line))

        sandbox.commands.run(
            'kimi -p "$AGENT_PROMPT" --output-format stream-json'
            + (' --session "$AGENT_SESSION_ID"' if session_id else ""),
            cwd="/home/user/work",
            timeout=300,
            envs={
                "HTTPS_PROXY": proxy,
                "HTTP_PROXY": proxy,
                "NO_PROXY": "localhost,127.0.0.1",
                "AGENT_PROMPT": prompt,
                "KIMI_MODEL_API_KEY": api_key,
                "KIMI_MODEL_PROVIDER_TYPE": "openai",
                "KIMI_MODEL_BASE_URL": "https://openrouter.ai/api/v1",
                "KIMI_MODEL_NAME": "moonshotai/kimi-k2.5",
                "KIMI_MODEL_MAX_CONTEXT_SIZE": "262144",
                "KIMI_MODEL_CAPABILITIES": "tool_use",
                "AGENT_SESSION_ID": session_id or "",
            },
            on_stdout=on_stdout,
            on_stderr=lambda chunk: print(chunk, end="", file=sys.stderr),
        )
        if pending.strip():
            event(json.loads(pending))
        if not next_session_id:
            raise RuntimeError("Agent did not return a session ID")
        print("\nSession:", next_session_id)
        return next_session_id

    session_id = execute(
        "Read request.txt and write reply.md with a short response to the customer."
    )
    execute(
        "Logistics has confirmed delivery on September 22, 2026 instead. Update reply.md with the new date.",
        session_id,
    )
    print("reply.md\n" + sandbox.files.read("/home/user/work/reply.md"))
finally:
    sandbox.kill()

package main

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"log"
	"os"
	"strings"
	"time"

	"github.com/abox-dev/sdk/packages/go-sdk"
)

func run() (err error) {
	apiKey := os.Getenv("OPENROUTER_API_KEY")
	if apiKey == "" {
		return errors.New("OPENROUTER_API_KEY is required")
	}
	proxy := os.Getenv("SANDBOX_PROXY_URL")
	if proxy == "" {
		proxy = "https://sandbox-proxy.agentbox.ru:65181"
	}
	ctx, cancel := context.WithTimeout(context.Background(), 8*time.Minute)
	defer cancel()
	client, err := agentbox.NewClient()
	if err != nil {
		return err
	}
	sandbox, err := client.Sandboxes.Create(ctx, &agentbox.CreateSandboxOptions{Template: "kimi", Timeout: 10 * time.Minute})
	if err != nil {
		return err
	}
	defer func() {
		cleanupCtx, stop := context.WithTimeout(context.Background(), 30*time.Second)
		defer stop()
		_, cleanupErr := sandbox.Kill(cleanupCtx)
		err = errors.Join(err, cleanupErr)
	}()
	if _, err := sandbox.Files.MakeDir(ctx, "/home/user/work"); err != nil {
		return err
	}
	if _, err := sandbox.Files.WriteText(ctx, "/home/user/work/request.txt", "Customer Acme asks when order 1042 will arrive. Order 1042 shipped on September 18, 2026. Estimated delivery is September 21, 2026. Tracking number: AB1042.\n", nil); err != nil {
		return err
	}
	execute := func(prompt, sessionID string) (string, error) {
		var pending, nextSessionID string
		var streamErr error
		event := func(line string) {
			if strings.TrimSpace(line) == "" || streamErr != nil {
				return
			}
			var message struct {
				Type      string `json:"type"`
				Role      string `json:"role"`
				Content   string `json:"content"`
				SessionID string `json:"session_id"`
				ToolCalls []struct {
					Function struct {
						Name string `json:"name"`
					} `json:"function"`
				} `json:"tool_calls"`
			}
			if err := json.Unmarshal([]byte(line), &message); err != nil {
				streamErr = err
				return
			}
			if message.Role == "assistant" {
				if message.Content != "" {
					fmt.Println(message.Content)
				}
				for _, call := range message.ToolCalls {
					fmt.Println("Tool:", call.Function.Name)
				}
			}
			if message.Type == "session.resume_hint" {
				nextSessionID = message.SessionID
			}
		}
		command := "kimi -p \"$AGENT_PROMPT\" --output-format stream-json"
		if sessionID != "" {
			command += " --session \"$AGENT_SESSION_ID\""
		}
		commandCtx, stop := context.WithTimeout(ctx, 5*time.Minute)
		defer stop()
		_, err := sandbox.Commands.Run(commandCtx, "sh", &agentbox.CommandOptions{
			Args: []string{"-lc", command},
			Cwd:  "/home/user/work",
			Env: map[string]string{
				"HTTPS_PROXY":                 proxy,
				"HTTP_PROXY":                  proxy,
				"NO_PROXY":                    "localhost,127.0.0.1",
				"AGENT_PROMPT":                prompt,
				"KIMI_MODEL_API_KEY":          apiKey,
				"KIMI_MODEL_PROVIDER_TYPE":    "openai",
				"KIMI_MODEL_BASE_URL":         "https://openrouter.ai/api/v1",
				"KIMI_MODEL_NAME":             "moonshotai/kimi-k2.5",
				"KIMI_MODEL_MAX_CONTEXT_SIZE": "262144",
				"KIMI_MODEL_CAPABILITIES":     "tool_use",
				"AGENT_SESSION_ID":            sessionID,
			},
			OnStdout: func(chunk []byte) {
				pending += string(chunk)
				for {
					line, rest, found := strings.Cut(pending, "\n")
					if !found {
						break
					}
					pending = rest
					event(line)
				}
			},
			OnStderr: func(chunk []byte) { fmt.Fprint(os.Stderr, string(chunk)) },
		})
		if err != nil {
			return "", err
		}
		event(pending)
		if streamErr != nil {
			return "", streamErr
		}
		if nextSessionID == "" {
			return "", errors.New("agent did not return a session ID")
		}
		fmt.Println("\nSession:", nextSessionID)
		return nextSessionID, nil
	}
	sessionID, err := execute("Read request.txt and write reply.md with a short response to the customer.", "")
	if err != nil {
		return err
	}
	if _, err := execute("Logistics has confirmed delivery on September 22, 2026 instead. Update reply.md with the new date.", sessionID); err != nil {
		return err
	}
	report, err := sandbox.Files.ReadText(ctx, "/home/user/work/reply.md", "")
	if err != nil {
		return err
	}
	fmt.Println("reply.md\n" + report)
	return nil
}

func main() {
	if err := run(); err != nil {
		log.Fatal(err)
	}
}

Сообщения с role: assistant содержат текст в content и вызовы в tool_calls. Результат инструмента приходит с role: tool. В конце session.resume_hint сообщает session_id. Пример передаёт этот ID в --session. Это поток сообщений и результатов инструментов, а не отдельных токенов. Процесс должен завершиться успешно до чтения итогового файла.

История сессии и файлы находятся в песочнице. Для следующего вызова сохраните её вместе с ID сессии или поставьте на паузу. Полный протокол и параметры CLI описаны в справочнике Kimi Code.

Kimi Code ​

Подключение ​

Подготовьте ответ клиенту ​

События и продолжение сессии ​

Kimi Code

Подключение

Подготовьте ответ клиенту

События и продолжение сессии