日本語
implementation("ai.sunra.client:sunra-client:0.1.5")
subscribe
import ai.sunra.client.*; import ai.sunra.client.queue.*; import java.util.Map; import com.google.gson.JsonObject; import java.util.function.Consumer; ClientConfig config = ClientConfig.builder() .withCredentials(CredentialsResolver.fromEnv()) .build(); SunraClient client = SunraClient.withConfig(config); Map<String, Object> input = Map.of( "prompt", "公園で走っている犬"); Consumer<QueueStatus.StatusUpdate> statusUpdateHandler = update -> { String status = update.getStatus().toString(); String message = String.format("\nステータス更新: %s, リクエストID: %s", status, update.getRequestId()); System.out.println(message); }; SubscribeOptions<JsonObject> options = SubscribeOptions.<JsonObject>builder() .input(input) .resultType(JsonObject.class) .onQueueUpdate(statusUpdateHandler) .logs(true) .build(); // subscribe リクエストを変数に保存して出力する Output<JsonObject> response = client.subscribe("black-forest-labs/flux-kontext-pro/text-to-image", options); System.out.println("完了しました!"); System.out.println(response.getData());
request_id
import ai.sunra.client.*; import ai.sunra.client.queue.*; import java.util.Map; import com.google.gson.JsonObject; import java.util.function.Consumer; ClientConfig config = ClientConfig.builder() .withCredentials(CredentialsResolver.fromEnv()) .build(); SunraClient client = SunraClient.withConfig(config); Map<String, Object> input = Map.of( "prompt", "公園で走っている犬"); Consumer<QueueStatus.StatusUpdate> statusUpdateHandler = update -> { String status = update.getStatus().toString(); String message = String.format("\nステータス更新: %s, リクエストID: %s", status, update.getRequestId()); System.out.println(message); }; SubscribeOptions<JsonObject> options = SubscribeOptions.<JsonObject>builder() .input(input) .resultType(JsonObject.class) .onQueueUpdate(statusUpdateHandler) .logs(true) .build(); // subscribe リクエストを変数に保存して出力する var request = client.queue().submit("black-forest-labs/flux-kontext-pro/text-to-image", options);
import ai.sunra.client.*; import ai.sunra.client.queue.*; ClientConfig config = ClientConfig.builder() .withCredentials(CredentialsResolver.fromEnv()) .build(); SunraClient client = SunraClient.withConfig(config); var job = client.queue().status(QueueStatusOptions.withRequestId("pd_eTYYuw4EqYLzRBHgnAMHA8zH"));
import ai.sunra.client.*; import ai.sunra.client.queue.*; ClientConfig config = ClientConfig.builder() .withCredentials(CredentialsResolver.fromEnv()) .build(); SunraClient client = SunraClient.withConfig(config); var result = client.queue().result(QueueStatusOptions.withRequestId("pd_eTYYuw4EqYLzRBHgnAMHA8zH"));