メッセージの作成

本番環境のHTTPリクエストはhttps://api.mosi.cnを使用します。以下の例を実行する前に、MOSS_API_ORIGINをhttps://api.mosi.cnに、MOSS_API_KEYをお使いのMOSS APIキーに設定してください。

リクエストパラメータ

フィールド型指定説明

model: string必須

nex-n2.6 または固定スナップショット nex-n2.6-2026-11-05 を使用します。

messages: array<object>必須

対話メッセージと必要な履歴を渡します。

messages[].role: string必須

user または assistant を使用します。ツールの結果は user メッセージに含めます。

messages[].content: string または array必須

テキストのみの場合は文字列を使用できます。画像は type: image のコンテンツブロックを使用し、source に URL または Base64 を指定します。Messages は動画に対応していません。

max_tokens: integer指定してください

出力トークンの予算です。本番環境のデフォルトは8192、パラメータの上限は131072です。例では明示的に1024を渡しています。

stream: boolean任意

true を指定するとストリーミング応答になります。

tools: array<object>任意

クライアント側で実行する関数ツールに対応しています。

version: string任意

省略できます。明示する場合は 2026-11-05 を指定し、model で選択したスナップショットと一致させてください。

レスポンスフィールド

フィールド型説明

model: string

今回の生成に使用されたスナップショット ID です。

content: array<object>

type が text のブロックから text を読み取ります。ツール呼び出しブロックの type は tool_use です。

stop_reason: string または null

終了理由です。tool_use はクライアントでツールを実行する必要があることを示します。

usage: object

今回の生成の使用量。

Anthropicクライアントの接続

https://api.mosi.cn/v1/messages にリクエストを送信します。x-api-key に MOSS API キーを指定し、anthropic-version: 2023-06-01 を設定します。

リクエスト例

curl -X POST "$MOSS_API_ORIGIN/v1/messages" \
  -H 'Content-Type: application/json' \
  -H "x-api-key: $MOSS_API_KEY" \
  -H 'anthropic-version: 2023-06-01' \
  -d '{
  "model": "nex-n2.6",
  "messages": [
    {
      "role": "user",
      "content": "17 × 23 の結果だけを答えてください。"
    }
  ],
  "max_tokens": 1024
}'

import os
import requests

url = os.environ["MOSS_API_ORIGIN"].rstrip("/") + "/v1/messages"
headers = {
    "Content-Type": 'application/json',
    "x-api-key": os.environ["MOSS_API_KEY"],
    "anthropic-version": '2023-06-01',
}

payload = {'model': 'nex-n2.6',
 'messages': [{'role': 'user', 'content': '17 × 23 の結果だけを答えてください。'}],
 'max_tokens': 1024}

response = requests.post(url, headers=headers, json=payload, timeout=(10, 120))
response.raise_for_status()
print(response.text)

async function main() {
  const origin = process.env.MOSS_API_ORIGIN;
  if (!origin) throw new Error("Set MOSS_API_ORIGIN");
  const url = origin.replace(/\/+$/, "") + "/v1/messages";
  const apiKey = process.env.MOSS_API_KEY;
  if (!apiKey) throw new Error("Set MOSS_API_KEY");
  const headers: Record<string, string> = {
    "Content-Type": "application/json",
    "x-api-key": apiKey,
    "anthropic-version": "2023-06-01",
  };

  const payload = {
    "model": "nex-n2.6",
    "messages": [
      {
        "role": "user",
        "content": "17 × 23 の結果だけを答えてください。"
      }
    ],
    "max_tokens": 1024
  };

  const response = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify(payload),
  });
  if (!response.ok) {
    throw new Error("HTTP " + response.status + ": " + await response.text());
  }
  console.log(await response.text());
}

main().catch((error: unknown) => {
  console.error(error);
  process.exitCode = 1;
});

レスポンスの抜粋です。通常のテキスト応答が自然終了した場合、stop_reason は end_turn です。

{
  "type": "message",
  "role": "assistant",
  "model": "nex-n2.6-2026-11-05",
  "stop_reason": "end_turn",
  "usage": {
    "input_tokens": 22,
    "output_tokens": 22
  },
  "content": [
    {
      "type": "text",
      "text": "\n\n391"
    }
  ]
}

stream: true を指定するとストリーミング応答になります。content_block_delta の text_delta からテキストを読み取り、message_stop を受信したら終了します。入力使用量は message_start の message.usage、出力使用量は message_delta の usage から読み取ります。まず HTTP ステータスを確認し、ストリーム開始後もエラーイベントと正常終了マーカーを確認してください。途中で接続が切れた場合は、未完了の応答として扱います。

curl -N -X POST "$MOSS_API_ORIGIN/v1/messages" \
  -H 'Content-Type: application/json' \
  -H "x-api-key: $MOSS_API_KEY" \
  -H 'anthropic-version: 2023-06-01' \
  -d '{
  "model": "nex-n2.6",
  "messages": [
    {
      "role": "user",
      "content": "17 × 23 の結果だけを答えてください。"
    }
  ],
  "max_tokens": 1024,
  "stream": true
}'

import os
import requests

url = os.environ["MOSS_API_ORIGIN"].rstrip("/") + "/v1/messages"
headers = {
    "Content-Type": 'application/json',
    "x-api-key": os.environ["MOSS_API_KEY"],
    "anthropic-version": '2023-06-01',
}

payload = {'model': 'nex-n2.6',
 'messages': [{'role': 'user', 'content': '17 × 23 の結果だけを答えてください。'}],
 'max_tokens': 1024,
 'stream': True}

with requests.post(url, headers=headers, json=payload, stream=True, timeout=(10, 120)) as response:
    response.raise_for_status()
    response.encoding = "utf-8"
    for line in response.iter_lines(chunk_size=1, decode_unicode=True):
        print(line, flush=True)

async function main() {
  const origin = process.env.MOSS_API_ORIGIN;
  if (!origin) throw new Error("Set MOSS_API_ORIGIN");
  const url = origin.replace(/\/+$/, "") + "/v1/messages";
  const apiKey = process.env.MOSS_API_KEY;
  if (!apiKey) throw new Error("Set MOSS_API_KEY");
  const headers: Record<string, string> = {
    "Content-Type": "application/json",
    "x-api-key": apiKey,
    "anthropic-version": "2023-06-01",
  };

  const payload = {
    "model": "nex-n2.6",
    "messages": [
      {
        "role": "user",
        "content": "17 × 23 の結果だけを答えてください。"
      }
    ],
    "max_tokens": 1024,
    "stream": true
  };

  const response = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify(payload),
  });
  if (!response.ok) {
    throw new Error("HTTP " + response.status + ": " + await response.text());
  }
  if (!response.body) throw new Error("Missing response body");
  const reader = response.body.getReader();
  const decoder = new TextDecoder();
  try {
    while (true) {
      const { value, done } = await reader.read();
      if (done) break;
      process.stdout.write(decoder.decode(value, { stream: true }));
    }
    process.stdout.write(decoder.decode());
  } finally {
    reader.releaseLock();
  }
}

main().catch((error: unknown) => {
  console.error(error);
  process.exitCode = 1;
});

ストリーミング応答の抜粋です。

data: {"type":"message_start","message":{"type":"message","role":"assistant","model":"nex-n2.6-2026-11-05","usage":{"input_tokens":22,"output_tokens":0}}}

data: {"type":"content_block_delta","index":1,"delta":{"type":"text_delta","text":"39"}}

data: {"type":"message_delta","delta":{"stop_reason":"end_turn"},"usage":{"output_tokens":25}}

data: {"type":"message_stop"}

前回の完全なリクエストと非ストリーミングレスポンスを、それぞれrequest.jsonとresponse.jsonとして保存します。HTTPの例ではjqを使用して返送リクエストを組み立てます。以下の例では固定のデモ結果を返送します。実際に連携する際は、まずツールを検証して実行し、その後に結果の内容を置き換えます。

set -e
assistant="$(jq -c '{role:"assistant",content:.content}' response.json)"
tool_id="$(jq -er 'first(.content[] | select(.type == "tool_use") | .id) // empty' response.json)"
payload="$(jq --argjson assistant "$assistant" --arg id "$tool_id" \
  '.stream = false | del(.stream_options) | .messages += [$assistant, {role:"user",content:[{type:"tool_result",tool_use_id:$id,content:"照会が完了しました"}]}]' request.json)"
curl -X POST "$MOSS_API_ORIGIN/v1/messages" \
  -H 'Content-Type: application/json' \
  -H "x-api-key: $MOSS_API_KEY" \
  -H 'anthropic-version: 2023-06-01' \
  --data-binary "$payload"

import json
from pathlib import Path
import os
import requests

url = os.environ["MOSS_API_ORIGIN"].rstrip("/") + "/v1/messages"
headers = {
    "Content-Type": 'application/json',
    "x-api-key": os.environ["MOSS_API_KEY"],
    "anthropic-version": '2023-06-01',
}

payload = json.loads(Path("request.json").read_text(encoding="utf-8"))
reply = json.loads(Path("response.json").read_text(encoding="utf-8"))
assistant = {"role": "assistant", "content": reply["content"]}
tool_id = next(block["id"] for block in reply["content"] if block["type"] == "tool_use")
tool_result = {
    "role": "user",
    "content": [{"type": "tool_result", "tool_use_id": tool_id, "content": "照会が完了しました"}],
}
payload["messages"] += [assistant, tool_result]
payload["stream"] = False
payload.pop("stream_options", None)

response = requests.post(url, headers=headers, json=payload, timeout=(10, 120))
response.raise_for_status()
print(response.text)

import { readFile } from "node:fs/promises";

async function main() {
  const origin = process.env.MOSS_API_ORIGIN;
  if (!origin) throw new Error("Set MOSS_API_ORIGIN");
  const url = origin.replace(/\/+$/, "") + "/v1/messages";
  const apiKey = process.env.MOSS_API_KEY;
  if (!apiKey) throw new Error("Set MOSS_API_KEY");
  const headers: Record<string, string> = {
    "Content-Type": "application/json",
    "x-api-key": apiKey,
    "anthropic-version": "2023-06-01",
  };

  const payload = JSON.parse(await readFile("request.json", "utf8"));
  const reply = JSON.parse(await readFile("response.json", "utf8"));
  const assistant = { role: "assistant", content: reply.content };
  const tool = reply.content.find((block: { type: string }) => block.type === "tool_use");
  if (!tool?.id) throw new Error("Missing tool_use block");
  const toolResult = {
    role: "user",
    content: [{ type: "tool_result", tool_use_id: tool.id, content: "照会が完了しました" }],
  };
  payload.messages.push(assistant, toolResult);
  payload.stream = false;
  delete payload.stream_options;

  const response = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify(payload),
  });
  if (!response.ok) {
    throw new Error("HTTP " + response.status + ": " + await response.text());
  }
  console.log(await response.text());
}

main().catch((error: unknown) => {
  console.error(error);
  process.exitCode = 1;
});

user メッセージの content に画像ブロックを追加します。Anthropic の source 形式で URL または Base64 を指定します。Messages は動画、ファイル、file_id に対応していません。公開メディア URL は MOSS からアクセスできる必要があります。エンコード済みメディアを含むリクエストボディ全体は 10 MiB 以下にしてください。

curl -X POST "$MOSS_API_ORIGIN/v1/messages" \
  -H 'Content-Type: application/json' \
  -H "x-api-key: $MOSS_API_KEY" \
  -H 'anthropic-version: 2023-06-01' \
  -d '{
  "model": "nex-n2.6",
  "messages": [
    {
      "role": "user",
      "content": [
        {
          "type": "text",
          "text": "この画像を説明してください。"
        },
        {
          "type": "image",
          "source": {
            "type": "url",
            "url": "https://httpbin.org/image/png"
          }
        }
      ]
    }
  ],
  "max_tokens": 1024
}'

import os
import requests

url = os.environ["MOSS_API_ORIGIN"].rstrip("/") + "/v1/messages"
headers = {
    "Content-Type": 'application/json',
    "x-api-key": os.environ["MOSS_API_KEY"],
    "anthropic-version": '2023-06-01',
}

payload = {'model': 'nex-n2.6',
 'messages': [{'role': 'user',
               'content': [{'type': 'text', 'text': 'この画像を説明してください。'},
                           {'type': 'image',
                            'source': {'type': 'url',
                                       'url': 'https://httpbin.org/image/png'}}]}],
 'max_tokens': 1024}

response = requests.post(url, headers=headers, json=payload, timeout=(10, 120))
response.raise_for_status()
print(response.text)

async function main() {
  const origin = process.env.MOSS_API_ORIGIN;
  if (!origin) throw new Error("Set MOSS_API_ORIGIN");
  const url = origin.replace(/\/+$/, "") + "/v1/messages";
  const apiKey = process.env.MOSS_API_KEY;
  if (!apiKey) throw new Error("Set MOSS_API_KEY");
  const headers: Record<string, string> = {
    "Content-Type": "application/json",
    "x-api-key": apiKey,
    "anthropic-version": "2023-06-01",
  };

  const payload = {
    "model": "nex-n2.6",
    "messages": [
      {
        "role": "user",
        "content": [
          {
            "type": "text",
            "text": "この画像を説明してください。"
          },
          {
            "type": "image",
            "source": {
              "type": "url",
              "url": "https://httpbin.org/image/png"
            }
          }
        ]
      }
    ],
    "max_tokens": 1024
  };

  const response = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify(payload),
  });
  if (!response.ok) {
    throw new Error("HTTP " + response.status + ": " + await response.text());
  }
  console.log(await response.text());
}

main().catch((error: unknown) => {
  console.error(error);
  process.exitCode = 1;
});

メッセージの作成（Messages）

リクエストパラメータ

レスポンスフィールド

Anthropicクライアントの接続

関連ドキュメント