批处理scala API post请求

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import scala.concurrent.Future
import scala.util.{Failure, Success}

object BatchProcessing {
  def main(args: Array[String]): Unit = {
    implicit val system = ActorSystem()
    implicit val materializer = ActorMaterializer()
    implicit val executionContext = system.dispatcher

    val url = "http://example.com/api"
    val data = """{"key": "value"}"""

    val request = HttpRequest(
      method = HttpMethods.POST,
      uri = url,
      entity = HttpEntity(ContentTypes.`application/json`, data)
    )

    val responseFuture: Future[HttpResponse] = Http().singleRequest(request)

    responseFuture.onComplete {
      case Success(response) =>
        // 处理成功响应
        println(s"Request successful: ${response.status}")
        response.entity.toStrict(5.seconds).map(_.data.utf8String).foreach(println)
        system.terminate()
      case Failure(ex) =>
        // 处理失败情况
        println(s"Request failed: $ex")
        system.terminate()
    }
  }
}