如何在django应用程序中用azure服务总线替换芹菜任务？

Question

在Django应用程序中，我被要求使用azure服务总线而不是芹菜。

阅读提供的文档，但没有清楚地了解如何使用服务总线而不是芹菜任务。提供的任何建议都将非常有用。

Answer 1

在开始之前，我想强调一下Azure服务总线和芹菜之间的区别。

Azure服务总线：

Microsoft Azure Service Bus 是一个完全托管的企业集成消息代理。

您可以参考这篇文章来了解更多关于服务总线的信息

芹菜：

分布式任务队列。Celery 是基于分布式消息传递的异步任务队列/作业队列。

在你的情况下，我可以想到两种可能性：

< li >您希望使用Service Bus with Celery来代替其他消息代理。 < li >用服务总线替换芹菜

1：您想将Service Bus与Celery一起使用以代替其他消息代理。

您可以参考这篇文章来理解为什么celery需要一个消息代理。我不确定你现在用的是哪个消息代理，但是你可以使用Kombu库来满足你的需求。

Azure服务总线参考：https://docs.celeryproject.org/projects/kombu/en/stable/reference/kombu.transport.azureservicebus.html

其他参考:https://docs . celery project . org/projects/kombu/en/stable/reference/index . html

2：完全用服务总线替换芹菜以满足您的要求：

考虑

< li >消息发送者是生产者 < li >消息接收者是消费者

这是两个不同的应用程序，您必须处理它们。

您可以参考下面的内容来获得更多的示例代码。

https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/servicebus/azure-servicebus/samples

解释:

< li >每次您想要执行操作时，您可以从producer客户端向主题发送消息。 < li >消费者客户端-正在侦听的应用程序将接收消息并对其进行处理。您可以将您的定制流程附加到它上面——这样，无论何时在消费者客户端收到消息，您的定制流程都会得到执行。

以下是接收客户端的示例:

from azure.servicebus.aio import SubscriptionClient
import asyncio
import nest_asyncio
nest_asyncio.apply()

        
Receiving = True

#Topic 1 receiver : 
conn_str= "<>"
name="Allmessages1"
SubsClient = SubscriptionClient.from_connection_string(conn_str, name)
receiver =  SubsClient.get_receiver()

async def receive_message_from1():
    await receiver.open()
    print("Opening the Receiver for Topic1")
    async with receiver:
      while(Receiving):
        msgs =  await receiver.fetch_next()
        for m in msgs:
            print("Received the message from topic 1.....")
            ##### - Your code to execute when a message is received - ########
            print(str(m))
            ##### - Your code to execute when a message is received - ########
            await m.complete()
            
            
loop = asyncio.get_event_loop()
topic1receiver = loop.create_task(receive_message_from1())

以下行之间的部分将是每次收到消息时都会执行的指令。

##### - Your code to execute when a message is received - ########