我有一个rake任务,它解析一个流API并将数据输入到数据库中。流API是实时提要,为了让实时数据进入数据库,rake任务应该持续运行。一旦调用rake任务,它就会连续运行并解析数据。现在我已经启动了rake任务,它正在运行。问题是,如果我关闭终端或重启服务器,rake任务将停止。因此,我需要linux中的一个脚本(类似于用于启动或停止apache服务器的脚本),它执行以下操作:
1. start the rake task by calling rake command (rake parse:stream) from the RAILS-ROOT (application director
我试图使用多处理模块重新启动python进程,但是出现了"AssertionError:不能启动进程两次“。
我的问题
如何重新启动进程?
一旦它被终止,它为什么会变成僵尸
如何删除僵尸进程?
import time
from multiprocessing import Process
def worker ():
while True:
print "Inside the worker"
time.sleep(10)
p1 = Process(target=worker,name="worke
Python多处理池在Linux和Windows之间有不同的行为。
当按工作人员的数量运行方法时,在Linux中它运行的是作为参数给定的特定函数的作用域上的进程,但是在Windows中,每个工作人员在父进程的范围内运行,并再次使用它不应该使用的代码。
例如:(只用于使其与我的代码类似)
from multiprocessing import Pool, Event
from flask import Flask
print(">>> This code running for every each worker")
app = Flask(__name__