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", "花が咲いているお茶が入ったガラスのティーポットが、太陽の光が差し込む窓際の木製のテーブルに置かれ、穏やかな朝の光が差し込んでいます。",
"prompt_enhancer", true,
"aspect_ratio", "16:9",
"output_format", "jpeg",
"safety_tolerance", 2
);
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();
Output<JsonObject> response = client.subscribe("black-forest-labs/flux-kontext-max/text-to-image", options);
System.out.println("完了しました!");
System.out.println(response.getData());