TaskHandler.py 823 B

12345678910111213141516171819202122
  1. from handlers.HandlerBase import BaseHandler
  2. from model import DingTalkUtils
  3. import subprocess
  4. class SrcBookInfo(BaseHandler):
  5. def get(self):
  6. com = 'source ~/.bashrc && /root/.local/share/virtualenvs/DataCenter-EjFsiCkN/bin/python /root/DataCenter/app/etl/src/src_book_info.py'
  7. ex = subprocess.Popen(com, stdout=subprocess.PIPE, shell=True)
  8. out, err = ex.communicate()
  9. status = ex.wait()
  10. print("cmd out: ", out.decode())
  11. self.write('ok')
  12. DingTalkUtils.send('DataCenter任务刷新:' + out.decode())
  13. # val= os.popen('source ~/.bashrc && /root/.local/share/virtualenvs/DataCenter-EjFsiCkN/bin/python /root/DataCenter/app/etl/src/src_book_info.py')
  14. # self.write('ok')
  15. # DingTalkUtils.send('DataCenter任务刷新:'+val.read())