0

如果我们使用微服务架构，理想情况下单个函数定义应该在一个地方。

因此，如果我有一个包含订阅者功能的微服务。

我想从任何微服务向该订阅者发布一个事件。当它甚至在任何其他微服务中都不可用时，我将如何传递该函数的实例。

https://python-rq.org/docs/

with Connection(redis.from_url(redis_url)):
    q = Queue(queue_name)
    task = q.enqueue(func, kwargs=params)

我的 API 服务器基于烧瓶，我的脚本是一个单独的微服务容器，下面是我正在遵循的架构。

cron_scripts
    category1/
        - script_file.py // Enqueue Redis File
    category2/
flask_server
    - app
        - models
        - routes
        - tests
        - utils
            - queue // Defines my redis enqueue Wrapper
        - tasks
            - All Separate Task functions as per worker
    - init (Flask Init)

是否有更好的设计模式资源？请告诉我。

更新 -

这个回购确实有意义 - https://github1s.com/munisisazade/redis-pub-sub/

有评论吗？

4

0 回答 0