セロリタスクでgrpcのタイムアウトが発生する

Question

セロリタスクでGRPCサーバーに接続しようとしています。私はPythonのシェルを介してこのスニペットを実行すると、私は接続を確立し、GRPCメソッドを実行することができる午前コード

timeout = 1 
    host = '0.tcp.ngrok.io' 
    port = '7145' 
    channel = grpc.insecure_channel('{0}:{1}'.format(host, port)) 
    try: 
     grpc.channel_ready_future(channel).result(timeout=timeout) 
    except grpc.FutureTimeoutError: 
     sys.exit(1) 
    stub = stub(channel) 

の以下の部分を持っています。しかし、これをCeleryタスクを通して実行すると、grpc.FutureTimeoutErrorが得られ、接続は確立されません。

セロリの作業員は、grpcサーバーと同じマシン上にあります。私はsocketライブラリを使用してGRPCサーバーにpingを実行しようとしましたが、うまくいきました（いくつかのジャンクレスポンスを返しました）。

私はgrpcio==1.6.0をインストールしたPython 2.7を使用しています。セロリのバージョンは4.1.0です。任意のポインタが役立つだろう。

Answer 1

セロリはフードの下でフォークを使用していると思うし、gRPC 1.6はフォーク動作をサポートしていないと思う。

gRPC 1.7にアップデートしてみてください。