0

組み込みのcherrypyサーバーでweb.pyアプリケーションを実行しています。ユーザーがURLに投稿するときに外部スクリプトを実行したいのですが、スクリプトはPythonサブプロセスのバックグラウンドで実行されます。Popen呼び出しとweb.pyは、jqueryを使用してスクリプトの進行状況が監視されている別のページにリダイレクトされます。 ajaxリクエスト。しかし、ここではこれを適切に実装できません。コードスニペットは次のとおりです。必要に応じて詳細情報を提供できます。

        import web
    from multiprocessing import Process
    import subprocess, shlex
    import time, json
    from login import authorize, sessidGen

    def __callProcess(processString,mod='w',shell=False):
        if not shell: args = shlex.split(processString)
        else: args = processString
        out = open('./bteq/logs/output.log',mod)
        err = open('./bteq/logs/error.log',mod)
        p = subprocess.Popen(args,stdout=out,stderr=err,shell=shell)
        return p

    def setExec():
        __callProcess("chmod +x ./bteq/*.sh",shell=True)

    def bteqExec(filename,system):
        if system not in ['prod','da','cdw','cdw2','cert','']: return False
        processString = " ".join([filename,system])
        p = __callProcess(processString)
        return p.pid

    render = web.template.render('templates/',base='layout')
    render_plain = web.template.render('templates/')

    class Executor:     
        def GET(self):
            authorize()
            session = web.ctx.session
            inputs = web.input(sessid={},type={})
            if not inputs.sessid or session.id != inputs.sessid: web.seeother('/')
            if inputs.sessid and inputs.type:
                return render.executor('BTEQ Executor',inputs.type,inputs.sessid)
            else: raise web.seeother('/')

        def POST(self):
            authorize()
            session = web.ctx.session
            inputs = web.input(sessid={},type={},act={})
            if not inputs.sessid or session.id != inputs.sessid: web.seeother('/')
            if inputs and inputs.act == 'start':
                pid = bteqExec('python ./bteq/timer.py','')
                session.id = sessidGen()
                session.exctrpid = pid
                return web.seeother('/progress.htm')
            else: raise web.seeother('/')

    class progress:
        def GET(self):
            authorize()
            session = web.ctx.session
            inputs = web.input(ajax={})
            if inputs.ajax == 'true': 
                web.header('Content-Type', 'application/json')
                if session.count >= 100: session.count = 0
                session.count += 10
                pid = session.exctrpid
                out = open('./bteq/logs/output.log','r')
                err = open('./bteq/logs/error.log','r')
                output = ('<strong>OUTPUT:</strong><br>'+out.read()).replace('\n','<br>')
                err = err.read()
                if err:error = ('<strong>ERRORS:</strong><br>'+err.read()).replace('\n','<br>')
                else: error = None
                d = {'count':session.count,'msg':output,'err':error,'rc':pid,'session_id':session.session_id}
                return json.dumps(d)
            r = web.template.Template('$def with (title)\n$var title: $title\n')
            return render_plain.layout_pgbar(r('progress test'))

subprocess.Popenオブジェクトはピクルスできないため、セッション変数として入れることができません。進行状況クラスからp.poll（）とp.stdout.read（）を取得したいと思います。

また、LinuxとWindowsの両方でコードを実行できるようにしたいので、開発者をWindowsでセットアップし、Linuxサーバーにデプロイします。

誰かがここで私を助けてくれませんか...

ありがとうございました。

4

1 に答える 1

0

私はそれをマルチプロセッシング プロセスにし、スポーンされたプロセスからサブプロセスに対してp.wait（）を実行し、スポーンされたプロセスが残りのステップを処理し、結果をデータベースに更新します。

web.pyの進行状況ページは、データベースで実行の進行状況をチェックし、解決されます。

コード：

from multiprocessing import Process

class ProcHandler(Process):
    def __init__(self,  *args, **kwargs):
        #Initialize 
        Process.__init__(self, *args, **kwargs)

    def run(self):
        p = bteqExec('python ./bteq/timer.py','')
        rc = p.wait()
        # do update the resulting to database. and make the web.py 
        # Progress class read from database entry made by this Process.
        return
于 2013-02-24T13:13:51.773 に答える