slouchpie

slouchpie

Is it wise to default to always using Flow when using Broadway?

Greetings, comrades.

I have thoroughly gone through both the RabbitMQ Elixir tutorials (RabbitMQ tutorial - "Hello world!" | RabbitMQ) and the book “Concurrent Data Processing in Elixir”. GenStage is very cool, Flow is very cool and Broadway is very cool.

I have a question for veterans who are well-experienced in both Flow and Broadway. Both are capable of constructing GenStage pipelines but, as far as I can tell, Flow allows for “longer” pipelines with more intricate branching. If using a message broker, it seems like a theoretically “ideal” architecture which would afford maximum future extensibility would be one where Broadway acts as a gateway for Flow.

My question, in short, would be “can Broadway construct pipelines of the same arbitrary length and complexity as Flow”? If not, then could it be said that it is theoretically ideal (when not certain of long-term project requirements) to always use Flow when using Broadway? As I understand, Broadway is concerned about the AMQP side of things, whereas Flow is more concerned with making GenStages do magic concurrency things.

Thanks!

P.S. Flow is really really fun. I am going to try to apply it to caint (Use streams · Issue #5 · peaceful-james/caint · GitHub)

Most Liked

slouchpie

slouchpie

Necromancy sneak attack! I have been using these libs for a few days and am now 90% sure that I am right to default to always using flow with broadway, to orchestrate the genstages that process amqp events.

sodapopcan

sodapopcan

I’m sorry I don’t have the answer. I’ve never even used Broadway or Flow or GenStage. But I very much enjoyed the reviews of Caint.

BartOtten

BartOtten

Wow, just the project I was looking for in my attempt to bring a “suite of libs for total localized and translated apps”. Great work.

@paulsabou is also in for LLM Po-files. Great dev I once worked with. Maybe both projects can learn from each other: GitHub - paulsabou/gettext_llm: Elixir Gettext LLM based translation library

paulsabou

paulsabou

Thanks @BartOtten

Where Next?

Popular in Questions Top

Tee
can someone please explain to me how Enum.reduce works with maps
New
aalberti333
As the title describes, I’m trying to run Enum.map() over a list of key/value pairs, where the value is a map. My data looks like this: ...
New
_russellb
I want to try my hand at web scraping. What tools/libraries do I need to use. I’m hoping to turn this into something professional so don’...
New
New
lk-geimfari
What is most correct way to open, read and parse JSON file with poison? For example if we have example.json file in root of some projec...
New
script
If I have a string “1000 cfu/ml” . I want to remove the characters and / and space . So the string is like this "1000" What is the ...
New
Phillipp
Hey, I have a NanoPi-M3 and try to install Elixir on their Ubuntu image. I followed the Raspberry Pi installation instructions from the ...
New
rms.mrcs
Hi, I need to transform a list of numbers into a map where the keys are the indexes and the values are the original values of the list....
New
Mooodi
Given a string, how can I get access to its character by index? Enum.at("my_string", 2) doesn't work. Or rather, not char, but a substr...
New
romenigld
I am trying to run a deploy with docker and I successfully runned with this command: docker build -t romenigld/blog-prod . but when I t...
New

Other popular topics Top

peerreynders
Manning 2016 Halloween weekend sale via Deal of the Day Friday, October 28 - Half off all MEAPs - code WM102816LT Saturday, October 29 ...
326 29600 154
New
Tee
can someone please explain to me how Enum.reduce works with maps
New
openscript
Hello! Sorry for this astonishing simple question, but I’m really stuck. I try to set up the intellij-elixir plugin, but I don’t know ho...
New
jerry
Good day to you all. I have been struggling to get a query involving like and ilike to work. Can anyone assist me on this, please? pro...
New
KronicDeth
Elixir plugin for JetBrain’s IntelliJ Platform (including Rubymine) This is a plugin that adds support for Elixir to JetBrains IntelliJ...
289 35421 110
New
stefanchrobot
What’s the safe way to decode a JSON string into a struct? I want to avoid calling String.to_atom. Jason.decode can give me a map with st...
New
ashish173
I am using Ecto timestamps with postgres, I can see the timestamps() use the :naive_dateime but for my use case I wanted to store the ti...
New
fayddelight
I tried installing elixir 1.11.2 erlang 23.3.4 via asdf in my zsh shell. Enabled the versions locally and globally. When I list them ...
New
fireproofsocks
Forgive me if this is obvious, but how does one delete a database record WITHOUT selecting it first? https://hexdocs.pm/ecto/Ecto.Repo.h...
New
baxterw3b
Hi guys, i’m new in the Elixir world, and i have to say, that i love it! i’m having some problem to understand anonymous functions with ...
New

We're in Beta

About us Mission Statement