get_stats.py 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. # Copyright 2019 The gRPC Authors
  2. #
  3. # Licensed under the Apache License, Version 2.0 (the "License");
  4. # you may not use this file except in compliance with the License.
  5. # You may obtain a copy of the License at
  6. #
  7. # http://www.apache.org/licenses/LICENSE-2.0
  8. #
  9. # Unless required by applicable law or agreed to in writing, software
  10. # distributed under the License is distributed on an "AS IS" BASIS,
  11. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. # See the License for the specific language governing permissions and
  13. # limitations under the License.
  14. """Poll statistics from the server."""
  15. from __future__ import absolute_import
  16. from __future__ import division
  17. from __future__ import print_function
  18. import argparse
  19. import logging
  20. import grpc
  21. from grpc_channelz.v1 import channelz_pb2
  22. from grpc_channelz.v1 import channelz_pb2_grpc
  23. def run(addr):
  24. with grpc.insecure_channel(addr) as channel:
  25. channelz_stub = channelz_pb2_grpc.ChannelzStub(channel)
  26. # This RPC pulls server-level metrics, like sent/received messages,
  27. # succeeded/failed RPCs. For more info see:
  28. # https://github.com/grpc/grpc/blob/master/src/proto/grpc/channelz/channelz.proto
  29. response = channelz_stub.GetServers(channelz_pb2.GetServersRequest())
  30. print(f'Info for all servers: {response}')
  31. def main():
  32. parser = argparse.ArgumentParser()
  33. parser.add_argument('--addr',
  34. nargs=1,
  35. type=str,
  36. default='[::]:50051',
  37. help='the address to request')
  38. args = parser.parse_args()
  39. run(addr=args.addr)
  40. if __name__ == '__main__':
  41. logging.basicConfig()
  42. main()