在nsq.run（）之后，我的python脚本没有执行“pynsq”包中的代码块

Question

我正在尝试将“pynsq”包（messagebroker服务）用于我的django项目。但是，当我使用nsq.run（）命令使用nsq.Reader（）类运行异步使用者请求时，在该命令未执行之后，它会占用我的主线程和代码

例如：-如nsq.run（）之后的图片所示，我正在尝试打印（“hello”），但在运行此.py脚本时，打印函数没有调用。我已尽力找到解决方案

在我的django项目中可以使用这个包吗？因为当我在nsq.run（）之后运行这个脚本时，我的代码块没有执行

请任何人都可以建议我在django项目中使用此软件包的解决方案

Answer 1

nsq.run()函数在后台启动事件循环。基本上，它是一个永远运行的while循环。因此，在这一行之后编写的任何代码都不会被执行

please can anyone suggest me the solution for this to use this package in my django project.

您可以在django进程之外的单独进程中运行nsq，然后使用类似Celery的东西在这两个进程之间传递消息