在我的django pod 中启动芹菜节拍和工作进程的最简单方法是什么?
我正在将我的 Openshift v2 Django 应用程序迁移到 Openshift v3。我正在使用专业订阅。我真的是Openshift v3、Docker、容器和Kubernetes的菜鸟。我已经使用本教程 https://blog.openshift.com/migrating-django-applications-openshift-3/来迁移我的应用程序(效果很好)。
我现在正在为如何开始芹菜而苦恼。在 Openshift 2 上,我只是post_start使用了一个动作钩子:
source $OPENSHIFT_HOMEDIR/python/virtenv/bin/activate
python $OPENSHIFT_REPO_DIR/wsgi/podpub/manage.py celery worker
--pidfile="$OPENSHIFT_DATA_DIR/celery/run/%n.pid"
--logfile="$OPENSHIFT_DATA_DIR/celery/log/%n.log"
python $OPENSHIFT_REPO_DIR/wsgi/podpub/manage.py celery beat
--pidfile="$OPENSHIFT_DATA_DIR/celery/run/celeryd.pid"
--logfile="$OPENSHIFT_DATA_DIR/celery/log/celeryd.log" &
-c 1
--autoreload &
这是一个非常简单的设置。它只是使用 django 数据库作为消息代理。没有兔子什么的。
为此,会适合做一个开放式的"工作"吗?或者更好地使用Powershift图像(https://pypi.python.org/pypi/powershift-image)操作命令?但我不明白如何执行它们。
这是我唯一的应用程序的当前部署配置">
apiVersion: v1
kind: DeploymentConfig
metadata:
annotations:
openshift.io/generated-by: OpenShiftNewApp
creationTimestamp: 2017-12-27T22:58:31Z
generation: 67
labels:
app: django
name: django
namespace: myproject
resourceVersion: "68466321"
selfLink: /oapi/v1/namespaces/myproject/deploymentconfigs/django
uid: 64600436-ab49-11e7-ab43-0601fd434256
spec:
replicas: 1
selector:
app: django
deploymentconfig: django
strategy:
activeDeadlineSeconds: 21600
recreateParams:
timeoutSeconds: 600
resources: {}
rollingParams:
intervalSeconds: 1
maxSurge: 25%
maxUnavailable: 25%
timeoutSeconds: 600
updatePeriodSeconds: 1
type: Recreate
template:
metadata:
annotations:
openshift.io/generated-by: OpenShiftNewApp
creationTimestamp: null
labels:
app: django
deploymentconfig: django
spec:
containers:
- image: docker-registry.default.svc:5000/myproject/django@sha256:6a0caac773acc65daad2e6ac87695f9f01ae3c99faba14536e0ec2b65088c808
imagePullPolicy: Always
name: django
ports:
- containerPort: 8080
protocol: TCP
resources: {}
terminationMessagePath: /dev/termination-log
terminationMessagePolicy: File
volumeMounts:
- mountPath: /opt/app-root/src/data
name: data
dnsPolicy: ClusterFirst
restartPolicy: Always
schedulerName: default-scheduler
securityContext: {}
terminationGracePeriodSeconds: 30
volumes:
- name: data
persistentVolumeClaim:
claimName: django-data
test: false
triggers:
- type: ConfigChange
- imageChangeParams:
automatic: true
containerNames:
- django
from:
kind: ImageStreamTag
name: django:latest
namespace: myproject
lastTriggeredImage: docker-registry.default.svc:5000/myproject/django@sha256:6a0caac773acc65daad2e6ac87695f9f01ae3c99faba14536e0ec2b65088c808
type: ImageChange
我正在使用mod_wsgi快递,这是我 app.sh
ARGS="$ARGS --log-to-terminal"
ARGS="$ARGS --port 8080"
ARGS="$ARGS --url-alias /static wsgi/static"
exec mod_wsgi-express start-server $ARGS wsgi/application
非常感谢帮助。谢谢
我已经设法让它工作了,尽管我对它不太满意。我很快就会转移到postgreSQL数据库。这是我所做的:
wsgi_mod-express有一个名为service-script的选项,它可以启动实际应用程序之外的其他进程。所以我更新了我的 app.sh:
#!/bin/bash
ARGS=""
ARGS="$ARGS --log-to-terminal"
ARGS="$ARGS --port 8080"
ARGS="$ARGS --url-alias /static wsgi/static"
ARGS="$ARGS --service-script celery_starter scripts/startCelery.py"
exec mod_wsgi-express start-server $ARGS wsgi/application
注意最后的 ARGS=...线。
我创建了一个 python 脚本来启动我的芹菜工人并节拍。 startCelery.py:
import subprocess
OPENSHIFT_REPO_DIR="/opt/app-root/src"
OPENSHIFT_DATA_DIR="/opt/app-root/src/data"
pathToManagePy=OPENSHIFT_REPO_DIR + "/wsgi/podpub"
worker_cmd = [
"python",
pathToManagePy + "/manage.py",
"celery",
"worker",
"--pidfile="+OPENSHIFT_REPO_DIR+"/%n.pid",
"--logfile="+OPENSHIFT_DATA_DIR+"/celery/log/%n.log",
"-c 1",
"--autoreload"
]
print(worker_cmd)
subprocess.Popen(worker_cmd, close_fds=True)
beat_cmd = [
"python",
pathToManagePy + "/manage.py",
"celery",
"beat",
"--pidfile="+OPENSHIFT_REPO_DIR+"/celeryd.pid",
"--logfile="+OPENSHIFT_DATA_DIR+"/celery/log/celeryd.log",
]
print(beat_cmd)
subprocess.Popen(beat_cmd)
这实际上是有效的,但是当我尝试启动芹菜工人时,我一直收到一条消息说 ">当工作线程接受使用 pickle 序列化的消息时,以超级用户权限运行工作线程是一个非常糟糕的主意! 如果你真的想继续,那么你必须设置C_FORCE_ROOT环境变量(但在你这样做之前请考虑一下)。
尽管我将这些配置添加到我的 settings.py 以删除 pickle 序列化程序,但它一直给我同样的错误消息。
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACEEPT_CONTENT = ['json']
我不知道为什么。 最后,我C_FORCE_ROOT添加到我的.s2i/enviroment中
C_FORCE_ROOT=true
现在它正在工作,至少我是这么认为的。我的下一份工作只会在几个小时内运行。我仍然愿意接受任何进一步的建议和提示。