可以使用 Akka Stream 提供的限流操作进行全局速率控制。在请求 API 接口获取全局速率限制后，可以使用一下代码实现限流：

import akka.{ NotUsed, Done }
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._
import scala.concurrent._
import scala.concurrent.duration._

object Throttling extends App {
    implicit val system = ActorSystem("Throttling")
    implicit val materializer = ActorMaterializer()
    implicit val ec = system.dispatcher

    // 请求 API 接口获取全局速率限制
    val globalRateLimit = getGlobalRateLimitFromApi()

    // 创建一个 Source
    val source: Source[Int, NotUsed] = Source(1 to 100)

    // 在 Source 上使用 throttle 操作进行限速
    val throttledSource = source
        .throttle(globalRateLimit, 1.second, globalRateLimit, ThrottleMode.Shaping)

    // 使用 Sink 输出每个输出元素
    val sink: Sink[Int, Future[Done]] = Sink.foreach[Int](println)

    // 连接 Source 和 Sink
    throttledSource.runWith(sink).onComplete { _ =>
        system.terminate()
    }
}

// 获取全局速率限制
def getGlobalRateLimitFromApi(): Int = {
    // TODO: 调用 API 接口获取速率限制
    10
}

在上面的代码中，我们使用 throttle 操作对 source 做限速，其中第一个参数 globalRateLimit 表示全局速率限制，第二个参数 1.second 表示限速的时间窗口，第三个参数 globalRateLimit 表示可缓存的最大元素数，ThrottleMode.Shaping 表示使用令牌桶算法进行限速，以平均速率输出。

最后，我们使用 runWith 方法将限速后的 source