mchreader.py 767 B

12345678910111213141516171819202122232425262728293031
  1. import signal as sig
  2. import sys,getopt
  3. from MchDataCenter import mchDataCenter
  4. # from UserFetcher import UserFetcher
  5. if __name__ == '__main__':
  6. try:
  7. opts, args = getopt.getopt(sys.argv[1:],"h:p:",["host=",'port='])
  8. except Exception as ex:
  9. print(ex)
  10. sys.exit(2)
  11. rhost = ''
  12. rport=6379
  13. for o, val in opts:
  14. if o in ("-h", "--host"):
  15. rhost = val
  16. elif o in ('-p', "--port"):
  17. rport = int(val)
  18. else:
  19. print("Err argv")
  20. mchDataCenter.set_redis(rhost,rport)
  21. sig.signal(sig.SIGINT, lambda: mchDataCenter.stop())
  22. mchDataCenter.prepare_data()
  23. # fetcher = UserFetcher()
  24. # sig.signal(sig.SIGINT, lambda: fetcher.stop())
  25. # fetcher.run()