Use Cloud Pub/Sub

[htdvisser]

Use aws_sqs input/output, azure_queue_storage input/output or gcp_pubsub input/output instead of (or in addition to) Redis/RabbitMQ/MQTT in between the ingest and processing pipelines.