Majordomo API のpyzmq-mdpを使用したいと考えています。クライアントのリポジトリの例は、よくわかりません。
myclient.py では、この例は MDPClient API を使用せずに手動でソケットを作成します。さらに悪いことに、リクエストの作成には mdp_request メソッドが使用されます。しかし、私はこれまでこれを試しました:
class Client(MDPClient):
def on_timeout(self):
print "Client Timed out."
def main():
context = zmq.Context()
mdp_client = Client(context, "tcp://127.0.0.1:8888", SERVICE)
try:
mdp_client.request(["hello"], timeout=5000)
except RequestTimeout:
print "Timed Out."
if __name__ == '__main__':
main()
私はクライアントのみを実行しています。ブローカーなし。しかし、これは RequestTimeout 例外を発生させていません。次の疑問があります。
- サンプルが MDPClient API を実装していないのはなぜですか?
- 利用可能なリクエストメソッドがある場合、mdp_request メソッドの目的は何ですか?
- 私のアプローチの何が問題になっていますか?
明らかな何かが欠けていますか?いくつかのガイダンスをお願いします。