基于你的
CronJob
spec不传递环境变量
RABBIT_URL
.
您的代码看起来好像希望设置此变量,但实际上不是,这可能是它默认为
localhost
.
self.params = pika.URLParameters(env.RABBIT_URL)
你可能想要这样的东西:
apiVersion: batch/v1beta1
kind: CronJob
metadata:
name: scrape-news
spec:
concurrencyPolicy: Forbid
jobTemplate:
spec:
template:
metadata:
labels:
app: scrape-news
spec:
containers:
- name: scrape-news
image: SCRAPER_IMAGE
imagePullPolicy: Always
env:
- name: RABBIT_URL
value: cloudamqp.com
restartPolicy: Never
schedule: '* * * * *'
successfulJobsHistoryLimit: 3