I'm working on handling events coming from eventstoredb using spark put actually couldn't find a straightforward way to connect between them with pyspark. What I aim to do is to read events as stream with spark and do some logic on them or maybe read them as patch what is the standard way to do this.
Already searched on connectors or any relation between both tools but couldn't find any. I expect to make something similar how spark connect with kafka and read streams of events.
If you have any techniques or best practices on this topic it would be appreciated to share.