I'm building an async library for python called taskiq (https://taskiq-python.github.io/). It allows you to easily setup RPC over distributed queues. Currently I'm trying to add a monitoring to see what tasks are being executed.