擷取訊息批次結果

StreamResponse<BetaMessageBatchIndividualResponse> beta().messages().batches().resultsStreaming(params = BatchResultsParams.none(), requestOptions = RequestOptions.none())

GET/v1/messages/batches/{message_batch_id}/results

以 .jsonl 檔案的形式串流傳輸訊息批次的結果。

檔案中的每一行都是一個 JSON 物件，包含訊息批次中單一請求的結果。結果的順序不保證與請求的順序相同。請使用 custom_id 欄位將結果與請求配對。

在我們的使用者指南中進一步瞭解 Message Batches API

Parameters

BatchResultsParams params

Optional<String> messageBatchId⁠Path

ID of the Message Batch.

Optional<List<AnthropicBeta>> betas⁠Header

Optional header to specify the beta version(s) you want to use.

MESSAGE_BATCHES_2024_09_24("message-batches-2024-09-24")

PROMPT_CACHING_2024_07_31("prompt-caching-2024-07-31")

COMPUTER_USE_2024_10_22("computer-use-2024-10-22")

COMPUTER_USE_2025_01_24("computer-use-2025-01-24")

PDFS_2024_09_25("pdfs-2024-09-25")

TOKEN_COUNTING_2024_11_01("token-counting-2024-11-01")

TOKEN_EFFICIENT_TOOLS_2025_02_19("token-efficient-tools-2025-02-19")

OUTPUT_128K_2025_02_19("output-128k-2025-02-19")

FILES_API_2025_04_14("files-api-2025-04-14")

MCP_CLIENT_2025_04_04("mcp-client-2025-04-04")

MCP_CLIENT_2025_11_20("mcp-client-2025-11-20")

DEV_FULL_THINKING_2025_05_14("dev-full-thinking-2025-05-14")

INTERLEAVED_THINKING_2025_05_14("interleaved-thinking-2025-05-14")

CODE_EXECUTION_2025_05_22("code-execution-2025-05-22")

EXTENDED_CACHE_TTL_2025_04_11("extended-cache-ttl-2025-04-11")

CONTEXT_1M_2025_08_07("context-1m-2025-08-07")

CONTEXT_MANAGEMENT_2025_06_27("context-management-2025-06-27")

MODEL_CONTEXT_WINDOW_EXCEEDED_2025_08_26("model-context-window-exceeded-2025-08-26")

SKILLS_2025_10_02("skills-2025-10-02")

FAST_MODE_2026_02_01("fast-mode-2026-02-01")

OUTPUT_300K_2026_03_24("output-300k-2026-03-24")

USER_PROFILES_2026_03_24("user-profiles-2026-03-24")

USER_PROFILES_2026_08_18("user-profiles-2026-08-18")

USER_PROFILES_2026_09_04("user-profiles-2026-09-04")

ADVISOR_TOOL_2026_03_01("advisor-tool-2026-03-01")

MANAGED_AGENTS_2026_04_01("managed-agents-2026-04-01")

CACHE_DIAGNOSIS_2026_04_07("cache-diagnosis-2026-04-07")

DREAMING_2026_04_21("dreaming-2026-04-21")

THINKING_TOKEN_COUNT_2026_05_13("thinking-token-count-2026-05-13")

SERVER_SIDE_FALLBACK_2026_06_01("server-side-fallback-2026-06-01")

SERVER_SIDE_FALLBACK_2026_07_01("server-side-fallback-2026-07-01")

FALLBACK_CREDIT_2026_06_01("fallback-credit-2026-06-01")

FALLBACK_CREDIT_2026_07_01("fallback-credit-2026-07-01")

AGENT_MEMORY_2026_07_22("agent-memory-2026-07-22")

MID_CONVERSATION_TOOL_CHANGES_2026_07_01("mid-conversation-tool-changes-2026-07-01")

COMPACT_2026_01_12("compact-2026-01-12")

COMPUTER_USE_2025_11_24("computer-use-2025-11-24")

MCP_TUNNELS_2026_06_22("mcp-tunnels-2026-06-22")

STRUCTURED_OUTPUTS_2025_11_13("structured-outputs-2025-11-13")

TASK_BUDGETS_2026_03_13("task-budgets-2026-03-13")

THINKING_DISPLAY_UPDATES_2026_08_18("thinking-display-updates-2026-08-18")

CE_USER_MANAGEMENT_2026_07_13("ce-user-management-2026-07-13")

MID_CONVERSATION_OUTPUT_CONFIG_2026_07_01("mid-conversation-output-config-2026-07-01")

THINKING_BINDING_CONTROLS_2026_08_01("thinking-binding-controls-2026-08-01")

MID_CONVERSATION_SYSTEM_CLEAR_AT_2026_08_21("mid-conversation-system-clear-at-2026-08-21")

COMPACT_2026_09_04("compact-2026-09-04")

INLINE_TOOLS_2026_09_15("inline-tools-2026-09-15")

MCP_CLIENT_2026_09_15("mcp-client-2026-09-15")

CE_PLUGINS_2026_09_01("ce-plugins-2026-09-01")

SPEND_LIMIT_READS_2026_09_26("spend-limit-reads-2026-09-26")

TELEMETRY_DESTINATIONS_2026_08_11("telemetry-destinations-2026-08-11")

Optional<String> workspaceId⁠Header

Optional header to select the Workspace for this request. The value is a Workspace ID (for example, wrkspc_011CZkZaBF1tNoB5wlCeusgy).

Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace.

Returns

class BetaMessageBatchIndividualResponse { customId; result; }

This is a single line in the response .jsonl file and does not represent the response as a whole.

String customId

Developer-provided ID created for each request in a Message Batch. Useful for matching results to requests, as results may be given out of request order.

Must be unique for each request within the Message Batch.

BetaMessageBatchResult result

Processing result for this request.

Contains a Message output if processing was successful, an error response if processing failed, or the reason why processing was not attempted, such as cancellation or expiration.

One of the following:

擷取訊息批次結果

package com.anthropic.example;

import com.anthropic.client.AnthropicClient;
import com.anthropic.client.okhttp.AnthropicOkHttpClient;
import com.anthropic.core.http.StreamResponse;
import com.anthropic.models.beta.messages.batches.BatchResultsParams;
import com.anthropic.models.beta.messages.batches.BetaMessageBatchIndividualResponse;

public final class Main {
    private Main() {}

    public static void main(String[] args) {
        AnthropicClient client = AnthropicOkHttpClient.fromEnv();

        StreamResponse<BetaMessageBatchIndividualResponse> betaMessageBatchIndividualResponse = client.beta().messages().batches().resultsStreaming("message_batch_id");
    }
}