Skip to content

Custom Body Type or response_serializer for incrementally streaming large amounts of data back to the client #2777

Description

@korydraughn

Question

I'm using Beast 1.81 with Clang 13.0.0 to present a distributed data management API over HTTP.

I've been reading a lot of the documentation and it's not clear to me what the recommended solution is for streaming large amounts of data back to the client. The pages that look like they are close to what I want are:

At the moment, my application presents something similar to POSIX read. That is, it forces the client to make multiple read requests to the HTTP server. This isn't ideal, but is good enough for a first pass (I'm still getting familiar with Beast).

You can view the code in question here:

The application has a background thread pool for long running operations. I want to use that to incrementally stream the data back.

Q. Does a custom body type make sense here? Or would a response_serializer be better?
Q. Is transfer-encoding: chunked automatically supported by custom body types?
Q. Are there examples which demonstrate how to do this asynchronously?

BTW, thanks for the awesome library.

Activity

  1. ashtum commented on Dec 22, 2023

    @ashtum
    Collaborator

    You can utilize a http::buffer_body to send the response part by part. This example might help you: https://www.boost.org/doc/libs/1_84_0/libs/beast/doc/html/beast/more_examples/send_child_process_output.html.

    If you are reading from a file, you might want to consider using http::file_body, which performs all these steps automatically.

    Alternatively, you can create a custom body type that reads from a stream into a fixed-size buffer and returns the corresponding buffers until it reaches the end of the stream.

  2. korydraughn commented on Dec 22, 2023

    @korydraughn
    Author

    Thanks. I'll give that a try.

  3. korydraughn commented on Dec 24, 2023

    @korydraughn
    Author

    The send child process output example was exactly what I needed.

    Perhaps adding an async example that demonstrates the same thing would be helpful to others. Mostly to show how to manage the lifetime of the response_serializer across async calls.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions