我的客户使用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}$我做错什么了?我完全不明白这个错误。我在窗户下面
目前没有回答
相关问题 更多 >
编程相关推荐