如何修复grp中失败的DNS解析

2024-04-19 16:51:20 发布

您现在位置:Python中文网/ 问答频道 /正文

我的客户使用gRPC。我的问题是它不能编译,因为dns中的一个错误我无法删除。如果我对create part做了注释,那么它就可以工作了(但是我必须使用create part):

# example_consumer.py
import pika, os, time
import grpc
import garden_pb2_grpc
import garden_pb2

# Access the CLODUAMQP_URL environment variable and parse it (fallback to localhost)

url = os.environ.get('CLOUDAMQP_URL', 'amqp://lay5672')
params = pika.URLParameters(url)
connection = pika.BlockingConnection(params)
channel = connection.channel()  # start a channel
channel.queue_declare(queue='garden')  # Declare a queue
grpcChannel = grpc.insecure_channel('https://')  # connection 
stub = garden_pb2_grpc.GardenServiceStub(grpcChannel)  

my_garden = garden_pb2.Garden(
    id="5d0a61f86e95521de096efb3",
    position=garden_pb2.Garden.Position(lat=1, lng=2),
    size=garden_pb2.Garden.Size(height=10, width=20),
    garden=[],
    userID="5d0a61f86e95521de096efb3"
)

createRequest = garden_pb2.CreateRequest(
    garden=my_garden
)


def garden_process_function(msg):
    print("Received " + str(msg))
    print("This function can do something")
    time.sleep(1)  # delays for 5 seconds
    feature = stub.Create(createRequest)  # je dois appeler avec un objet create request
    return;


# create a function which is called on incoming messages
def callback(ch, method, properties, body):
    garden_process_function(body)


class Server(object):
    @staticmethod
    def receiveMsg():
        # set up subscription on the queue
        channel.basic_consume('garden',
                              callback,
                              auto_ack=True)
        # start consuming (blocks)
        channel.start_consuming()
        connection.close()


class App(object):
    @staticmethod
    def run():
        print('Running...')


if __name__ == '__main__':
    App.run()
    Server.receiveMsg()

但我有个错误:

^{pr2}$

我做错什么了?我完全不明白这个错误。我在窗户下面


Tags: importgrpcqueuedef错误createchannelfunction