look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we making the workers listen to different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image.rotate") >>> add.ap

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we making the workers listen to different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image.rotate") >>> add.ap

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we making the workers listen to different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image.rotate") >>> add.ap

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we making the workers listen to different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image.rotate") >>> add.ap

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we making the workers listen to different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image.rotate") >>> add.ap

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image

look at an example: Let’s pretend we have an application with lot of different tasks: some process video, others process images, and some gather collective intelligence about its users. Some of these tasks stock.nasdaq. We create three queues, video, image and lowpri that binds to the tasks exchange. For the queues we use the following binding keys: video: video.# image: image.# lowpri: misc.# Now we different queues: >>> add.apply_async(args=[filename], ... routing_key="video.compress") >>> add.apply_async(args=[filename, 360], ... routing_key="image