配置函数的流式返回-j9九游会登录

参考使用容器镜像创建函数完成容器镜像函数创建，并开启流式返回。请注意，函数超时时间配置需控制在300s以内，否则将导致函数保存失败。

为了确保函数能够正确返回流式数据，在函数的响应体生成过程中，建议分批次写入流式数据，以避免内存浪费。以下提供一个简单的java springboot应用返回流式数据的示例：

@springbootapplication
@restcontroller
public class springbootdemohelloworldapplication {
    private executorservice executor = executors.newcachedthreadpool();
    public static void main(string[] args) {
        springapplication.run(springbootdemohelloworldapplication.class, args);
    }
    /**
     * stream response
     * @return
     */
    @postmapping(value = "/invoke")
    public responseentity invoke(@requestbody map body) {
        responsebodyemitter emitter = new responsebodyemitter();
        executor.submit(() -> {
            try {
                emitter.send("hello \n", mediatype.text_event_stream);
                emitter.send("world \n", mediatype.text_event_stream);
                emitter.complete();
            } catch (exception ex) {
                emitter.completewitherror(ex);
            }
        });
        httpheaders responseheaders = new httpheaders();
        responseheaders.setcontenttype(mediatype.text_event_stream);
        return new responseentity(emitter, responseheaders, httpstatus.ok);
    }
}

参考创建http函数完成http函数创建，并开启流式返回。请注意，函数超时时间配置需控制在300s以内，否则将导致函数保存失败。

http函数的示例代码可参考容器镜像函数示例代码。

定制运行时函数需调用http://$runtime_api_addr/v1/runtime/invocation/response/$request_id的post方法返回流式数据。以下为一个简单的shell类型bootstrap示例：

#!/bin/sh
set -o pipefail
#processing requests loop
while true
do
  headers="$(mktemp)"
  # get an event
  event_data=$(curl -ss -ld "$headers" -x get "http://$runtime_api_addr/v1/runtime/invocation/request")
  # get request id from response header
  request_id=$(grep -fi x-cff-request-id "$headers" | tr -d '[:space:]' | cut -d: -f2)
  if [ -z "$request_id" ]; then
    continue
  fi 
  # send streamdata file content back to client
  curl -x post "http://$runtime_api_addr/v1/runtime/invocation/response/$request_id" -h "content-type:application/octet-stream" --data-binary "@code/streamdata.txt"
done