【Python:为长时间运行的后台进程生成或线程?】教程文章相关的互联网学习教程文章

Python:如何在python中运行嵌套并行进程?【代码】

我有交易者交易的数据集df.我有2个级别的for循环,如下所示:smartTrader =[]for asset in range(len(Assets)):df = df[df['Assets'] == asset]# I have some more calculations herefor trader in range(len(df['TraderID'])):# I have some calculations here, If trader is successful, I add his ID # to the list as followssmartTrader.append(df['TraderID'][trader])# some more calculations here which are related to t...

Python子进程调用不能使用grep【代码】

Python子进程调用应该按命令原样运行,但是它在抱怨是否有管道.这是我的代码:#!/usr/bin/pythonimport sys import subprocess import time service_name= "mysrvc" state ="STOPPED" mycmd ="sc query " + service_name + " " + "|" + " findstr" + " " + state print(mycmd) if subprocess.call(mycmd)==0:print("Service stopped successfully")我得到的错误是:ERROR: Invalid Option; Would you like to see help for the QUE...

python-从子进程实时打印标准输出【代码】

我想打印而不是捕获bash命令的输出(比this post更接近实时).例如,我有一个这样的脚本:from subprocess import Popen, PIPE, STDOUT cmd = 'rsync --rsh=ssh -rv thisdir/ servername:folder/' p = Popen(cmd.split() ,stdout=PIPE, stderr=STDOUT) output = p.communicate()[0] print output我希望从rsync实时打印文件传输的详细信息,就像从命令行进行rsync一样,而不是等待进程完成以打印输出.解决方法:尝试这样做:from subproce...

像命令行模拟器一样使用python子进程模块【代码】

我正在用Python为命令行应用程序编写测试框架.该应用程序将创建目录,在当前目录中调用其他shell脚本,并将在Stdout上输出. 我正在尝试将{Python-SubProcess,CommandLine}组合等同于{Selenium,Browser}.第一个组件在第二个组件上起作用,并检查是否期望输出.我面临以下问题 > Popen构造接受一条命令,并在该命令完成后返回.我想要的是该过程的实时处理程序,因此我可以运行进一步的命令验证,并在完成后最终关闭外壳>我可以编写一些基础结...

从python子进程运行linux grep命令【代码】

我知道已经有关于如何在python中使用子进程来运行linux命令的文章,但是我只是无法获得正确的语法.请帮忙.这是我需要运行的命令…/sbin/ifconfig eth1 | grep "inet addr" | awk -F: '{print $2}' | awk '{print $1}'好的,这是我目前遇到的语法错误…import subprocess self.ip = subprocess.Popen([/sbin/ifconfig eth1 | grep "inet addr" | awk -F: '{print $2}' | awk '{print $1}'])任何帮助,不胜感激.解决方法:这已经被很多遍...

将pandas数据框传递到python子进程中.Popen作为参数【代码】

我正在尝试从主脚本调用python脚本.我需要从主脚本中仅生成一个数据帧,然后将其作为参数传递给子流程脚本,以在子流程中使用. 以下是我尝试编写所需的python主脚本的尝试.from subprocess import PIPE, Popen import pandas as pdtest_dataframe = pd.read_excel(r'C:\test_location\file.xlsx',sheetname='Table')sp = Popen(["python.exe",'C:/capture/test.py'], shell=True, stdin=PIPE, stdout=PIPE, stderr=PIPE) sp.communic...

Python多重处理:RuntimeError:“队列对象仅应通过继承在进程之间共享”

我知道multiprocessing.Manager()以及如何将其用于创建共享对象.特别是可以在工作人员之间共享的队列.有question、question和question. 但是,这些链接没有提及为什么我们可以使用继承在进程之间共享.据我了解,在这种情况下仍然只能复制队列.解决方法:python中的Queue实现依赖于系统管道将数据从一个进程传输到另一个进程以及一些信号量,以保护对该管道的读写. 由于操作系统限制,管道在进程中被视为打开文件,并且只能在生成时与子进...

python-在生成和运行子进程时显示进度【代码】

我需要在生成和运行子流程时显示一些进度条或其他内容.如何使用python做到这一点?import subprocesscmd = ['python','wait.py'] p = subprocess.Popen(cmd, bufsize=1024,stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE) p.stdin.close() outputmessage = p.stdout.read() #This will print the standard output from the spawned process message = p.stderr.read()我可以使用此代码生成子流程,但是每过...

如何将python子进程stderr和stdout重定向到多个文件?【代码】

这个问题已经在这里有了答案: > Python subprocess get children’s output to file and terminal? 2个我只想将stderr和stdout重定向到多个文件.例如:stderr应该重定向到file_1和file_2. 我在下面使用重定向输出到单个文件.subprocess.Popen("my_commands",shell=True,stdout=log_file,stderr=err_file,executable="/bin/bash")上面的东西将stdout和stderr重定向到单个...

如何在PyQt4进程中使用多核python?

我正在pyqt4中编写一个必须读取并解析许多xml文件的应用程序.完成单线程处理需要花费一些时间来完成所有解析,并制作与该传入xml相对应的数千个python对象.我已经分析了代码,据我所知它是计算的,而不是I / O的. 我想使用工人农场模型(python中的?Process.Pool)将应用程序转换为多核模型以分散负载. 但是,我也希望能够通过信号通知工作人员更新gui的进度. 从我到目前为止所读的内容看来,QThread不具有多核功能(因为它在一个核上循环...

python-如何为子进程提供密码并同时获取stdout【代码】

我正在尝试检查远程计算机上是否存在可执行文件,然后运行所说的可执行文件.为此,我正在使用子进程来运行ssh< host>. ls< file&gt ;,如果成功,请运行ssh< host> &LT文件&gt ;. ssh当然要求输入密码,我想自动提供该密码.另外,我想从ls中获取返回码,并从运行命令中获取stdout和stderr. 因此,我知道需要用到communication()方法来避免死锁,但是我无法获得Popen(stdin)可以识别的密码.另外我正在使用Python 2.4.3,并停留在该版本上.这是...

python – 在Windows中暂停进程【代码】

我正在为Windows上的ffmpeg创建一个漂亮的小Python GUI前端(专门用于将视频转换为iPhone友好格式并自动将其导入iTunes并标记它),我希望它能够工作以便您可以如果你愿意,暂停进程并恢复它. 由于我将ffmpeg作为一个单独的进程启动,显而易见的解决方案是程序暂停进程(我知道可以在Windows中使用,Process Explorer可以执行此操作),但我无法弄清楚如何执行此操作.有没有人知道如何在Python中这样做?解决方法:您可以使用psutil(https://...

Python子进程使用超时终止【代码】

我正在使用python中的子进程模块运行一些shell脚本.如果shell脚本运行得很长,我喜欢杀死子进程.我认为如果我将timeout = 30传递给我的run(..)语句就足够了. 这是代码:try:result=run(['utilities/shell_scripts/{0} {1} {2}'.format(self.language_conf[key][1], self.proc_dir, config.main_file)],shell=True,check=True,stdout=PIPE,stderr=PIPE, universal_newlines=True, timeout=30,bufsize=100) except TimeoutExpired as ...

python – 在子进程Popen和通信之后关闭所有文件的正确方法【代码】

在我们的Ubuntu Linux机器上运行python Twisted应用程序时,我们遇到了可怕的“太多打开文件”的问题.在我们程序的许多地方,我们使用子进程Popen,如下所示:Popen('ifconfig ' + iface, shell=True, stdin=PIPE, stdout=PIPE, stderr=STDOUT, close_fds=True) output = process.stdout.read()而在其他地方我们使用子进程通信:process = subprocess.Popen(['/usr/bin/env', 'python', self._get_script_path(script_name)],stdin=su...

python – 我如何sudo当前进程?【代码】

是否可以使用sudo前端(如gksudo)来提升当前进程的权限?我知道我可以做到以下几点:sudo cat /etc/passwd-但我有兴趣这样做:sudo-become-root # magic function/command cat /etc/passwd-我正在用Python写作.我的用例是我有一个以用户身份运行的程序,但可能会遇到根目录所有的读/写文件.我想提示输入密码,获得root权限,执行我需要的操作,然后再选择删除权限. 我知道我可以将管理逻辑和非管理逻辑分离到单独的进程中,然后以root身份...