stuartc
I’m trying to generate a stream of JSON from an Ecto stream to be sent out via send_chunked/2 and chunk/2.
It appears that all the JSON libraries I can find are only for parsing.
With the exception of GitHub - TreyE/json_stream_encoder: Streaming encoder for JSON in elixir. · GitHub
I got stuck trying to use this library since it’s built around IO.binwrite which needs an IO device; I’m more comfortable with streams at the moment.
The gist of what I need is IO’ish device or a Stream of strings, but gives me the opportunity to format things as I go.
Individual items in the response aren’t big on their own, but there could be thousands of them.
Is there any library or approach anyone can share?
Where Next?
Trending in Questions
Other Trending Topics
Latest Phoenix Threads
Latest on Elixir Forum
Sponsor Spotlight
Supporting innovation across the BEAM ecosystem.
Categories:
Sub Categories:
Forums
Popular Tags
- #ecto
- #liveview
- #troubleshooting
- #learning-elixir
- #deployment
- #library
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #elixirconf
- #channels
- #exunit
- #discussion
- #code-sync
- #javascript
- #podcasts
- #onsite
- #dialyzer
- #docker
- #authentication
- #umbrella
- #full-time-contract
- #podcasts-by-brainlid
- #ecto-query
- #blog-post
- #elixir-ls
- #ai
- #elixirconf-us
- #phoenix_html
- #iex
- #graphql
- #genstage
- #websockets
- #supervisor
- #advent-of-code
- #distillery
- #processes
- #api
- #forms
- #hex
- #security
- #metaprogramming
Our Sponsors
Build Elixir applications with speed and confidence.
Supporting innovation across the BEAM ecosystem.
We build reliable cloud platforms for business-critical systems.
Catch errors, track performance, monitor hosts and more.
Error tracking, logs, uptime, and Just Enough APM. Built for developers.
Master modern tools, write cleaner code, and tackle real-world challenges.
Producing high quality Elixir screencasts since 2017.
The deployment platform built for Elixir: PaaS ease, VPS control.
The team behind Membrane, Popcorn, LiveDebugger. Available for hire.
Courses that'll move you from confusion to "Aha, now I get it!"
Showing Posts 1 to 5- Show Best Posts
- Show All (oldest first)
- Show All (newest first)
LostKobrakai
Ecto streams are not arbitrary, but essentially chunks. You always get a fixed(max) number of full rows, never partial rows. So your stream could essentially be:
Or switch to ndjson and just join the rows with newlines.
krasenyp
They might even query records as JSON, if the database supports it, and skip encoding in the application altogether.
stuartc
Thanks for this, I was going down this route but it felt clunky; but one thing that weirdly ironed out a lot was see that (from your example) that you can concat Streams with other enums. Which in hindsight feels obvious!
Anyway, thanks!
stuartc
Nice idea, I do that elsewhere in our app with LiveView, didn’t think of doing that with an HTTP api - I might just do that.
I think @LostKobrakai’s example applies equally to this as well, getting ecto to emit a stream of strings and wrapping them like that works just as well.
I’m understanding you correctly right?
LostKobrakai
Yeah. Stream vs Enum APIs is about the output, not the input. The inputs are usually similar / the same and accept any
Enumerables.