I'd like to pull Google PubSub messages using a Function App, and I'm trying to understand the best pattern. This is an integration between several systems, and one makes its data available with Google PubSub.
I'd like to pull the messages as continuously as possible, log them, publish them to Azure Service Bus, and then acknowledge each message.
Is this a job for a timer trigger? Maybe run every minute and loop, pulling all available messages? That's the only pattern I see, looking at the Google docs:
https://cloud.google.com/dotnet/docs/reference/Google.Cloud.PubSub.V1/latest/index
https://googleapis.dev/python/pubsub/latest/subscriber/index.html
(I don't mind doing this in C# or Python)
Google PubSub uses http under these libraries. But it seems like I might be missing a better option in these libraries, like maybe a listener object with a on_message, on_disconnect that I can keep running in an Azure functions, like on a normal messaging system.
