python - How can I use Pika to send and receive RabbitMQ messages? -

-

I am having some problem so that the pic is getting in the way of working with routing keys or exchanges, which It is compatible with AMQP or RabbitMQ documentation. I understand that the RabbitMQ documentation uses an earlier version of Pika, so I have ignored their example code

What I'm trying to do is a line, defines "order" And there are two consumers who handle "Production" of Exchange or Routing_ and who handle "Tests" by looking at the Rabbit MQ document which is directly using direct exchange and routing keys or Isi theme should be quite easy using Exchange.

Although the pica does not even know what to do with the exchanges and routing keys, using RabbitMQ management tool to inspect the queues, it is very clear that the pic or the message may be correctly queued Does not give or that RabbitMQ threw it

On the consumer side, it is not really clear how can I force a user to exchange or handle routing And the documentation is not really helping.

If I get ideas or exchange and routing keys, the message queue up well and is easily handled by my consumer.

Any sign or example code would be good for the people.

As it turns out, my understanding of AMQP was incomplete

< / P>

Customers :

After receiving the connection, the customer should not have anything else for the exchange name and the routing key we do not know This is how the queue will end. 

  channel.basic_publish (exchange = 'order', routing_key = "order.test.customer", body = pickle.dumps (data), attribute = pika.BasicProperties (content_type = "text /  
  Consumer   
 When the channel is open, we declare the exchange and queue  Channel.exchange_declare (exchange = 'order', type = "topic", durable = true, auto_delete = False) channel.queue_declare (queue) "test", durable = true, exclusive = false, auto_delete = False, callback = on_queue_declared) When the queue is ready, there is a good place in the "on_queue_declared" callback, Using Unji can bind the queue. 
 
  channel.queue_bind (queue = 'test', exchange = 'order', routing_key = 'order.test.customer') #handle_delivery is a callback that actually returns # Will handle by sending messages. The message sent on the "Order" exchange with the routing key "order.test.customer" will now be sent to the "Test" queue, Where consumers can choose it

Comments

Post a Comment

Popular posts from this blog

qt - switch/case statement in C++ with a QString type -

-
I want to use switch-case in my program but the compiler generates an error. How can I use the switch statement with QString ? The compiler gives me this error: The expression of the switch type 'QString' is invalid My code is as follows : boolStopWord (the word QString) {bool flag = false; Switch (word) {case "the": flag = true; break ; "On" case: flag = true; break ; Case "in": flag = true; break ; Case "your": flag = true; break ; Case "near": flag = true; break ; Case "all": flag = true; break ; Case "this": flag = true; break ; } Return flag; } How do I use the switch statement with a Caststring ? You can not use the switch statement in C ++ language with integral or enum types. You can formally enter the square type of object in the switch statement, but this means that the compiler will look for a user-defined conversion to convert it to an integral or enum type.
Read more

python - sqlite3.OperationalError: near "REFERENCES": syntax error - foreign key creating -

-
I'm trying to create a predefined key after checking the manual and I wrote it: Db.execute ("create table" Table 2 (id, integer primary key, somedata integer) "db.execute" (table creation table 2 does not exist (name text, maintain reference (id) ") and found this: sqlite 3. Operation error: near" references ": syntax error Your second ligne is wrong db.execute ("create table if table does not exist 2 (name text, my_id integer, foreign key (my_id) reference Maintenance (ID)) ") as explained
Read more

Python's equivalent for Ruby's define_method? -

-
What is a Python equivalent for Ruby's define_method , which is the dynamic generation of class methods will allow? (As can be seen in Wikipedia) Functions are first-class objects in Python and assign them The properties of a class or an example can be a way of doing the same thing as a Wikipedia example: colors = {"black": "000", "red": "F00", "green": "0f0", "yellow": "ff0", "blue": "00f", "magenta": "fff", "cyan": "0ff", "white": " FFF "} Class MyStream (ARR): Pass for Name, Code in colors.iteritems (): def _in_colour ( W code = code): return '& lt; Span style = "color:% s" & gt;% s & lt; / Span & gt; ' % (Code, self) setter (histrive, "in_" + name, _in_ color)
Read more