Ask Experienced Devs

1254 readers

1 users here now

Icon base by Delapouite under CC BY 3.0 with modifications to add a gradient

founded 2 years ago

MODERATORS

Ategon

Apache Beam - How to control/limit the concurrency process of ParDo ? (self.ask_experienced_devs)

submitted 8 months ago by hahattpro to c/ask_experienced_devs

0 comments fedilink hide all child comments

The problem is I am using beam.ParDo to call api, to enrich my data.

pipeline | "read_csv" >> beam.io.ReadFromCsv("...") 
                | "get_info_api" >> beam.ParDo(GetApiDoFN()) 
                | "write_output" >>  beam.io.WriteToBigQuery(...)

The problem is that api have limit. I need a way to control so it do not overload api or get 429 error.

I would like to set api call should not exceed 4 call / second.

How should I do it ?

no comments (yet)

sorted by: hot top controversial new old

there doesn't seem to be anything here