私は非同期メッセージキューを初めて使用しています。私のプロジェクトでは、kestrel、pykestrelにpython apiを使用しています（https://github.com/empower/pykestrel）。kestrelキューシステム用のpythonライブラリ
q.add（ "テストジョブ"）
実際にテストジョブは何ですか？
githubのページ上の例では、次の行を持っています。誰かがpykestrelの使用を示すいくつかの例を提供してもらえますか？
は、あなたの質問に
にコードをありがとう助けてくださいケストレルキューにメッセージを追加します。
kestrel.next()
は、キュー内の次のメッセージを取得します。
あなたは、コード内の完全なドキュメントを見つけることができます：ケストレルで使用することができMemcacheので動作します。基本的http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt
、何も：
https://github.com/empower/pykestrel/blob/master/kestrel/client.pyはまた、チョウゲンボウはmemcacheのあなたがここに見つけることができるプロトコルを使用しています。
後継の場合、元のプロジェクトはhttps://github.com/matterkkila/pykestrel/であり、新しいものであることに注意してください。
「テストジョブ」は、実際には、作業者が実行するアクションの説明です。たとえば、ビデオサイトの場合、新しいビデオを受信した後：
"MakeIcon('/path/to/video')"
あなたのワーカープロセスは、そのメッセージに基づいて何をすべきかを知っている必要があります。メッセージはより大きく、より多くの情報を含むことができる。
何でもかまいませんが、とにかくエンコードしてください。