我按照[ http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html ]中给出的所有步骤进行了操作.这是代码:
from __future__ import absolute_import
from celery import Celery
#app = Celery('tasks', broker='pyamqp://guest@localhost//')
app = Celery('tasks', backend='redis://localhost', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
Run Code Online (Sandbox Code Playgroud)
当我使用以下命令运行芹菜工作者时
celery -A tasks worker --loglevel=info
Run Code Online (Sandbox Code Playgroud)
设置后端时出现语法错误.这是错误消息:
[2018-07-10 16:37:21,970: CRITICAL/MainProcess] Unrecoverable error: SyntaxError('invalid syntax', ('c:\\users\\user_\\appdata\\local\\programs\\python\\python37-32\\lib\\site-packages\\celery\\backends\\redis.py', 22, 19, 'from . import async, base\n'))Traceback (most recent call last): File "c:\users\user_\appdata\local\programs\python\python37-32\lib\site-packages\kombu\utils\objects.py", line 42, in __get__ return obj.__dict__[self.__name__] KeyError: 'backend' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "c:\users\user_\appdata\local\programs\python\python37-32\lib\site-packages\celery\worker\worker.py", …Run Code Online (Sandbox Code Playgroud) 我正在寻找一种方法将一些 .mp4 视频文件(因为它们是由某些 python 应用程序生成的)“写入流”到谷歌云存储桶。python 应用程序已容器化并部署在 GKE 中,目前可以作为 Web 服务正常执行。但问题是,所有视频文件都是本地生成的,并存储在tmp/processedpod 内的路径 ( ) 中。
但是,我希望将视频文件写入 Google 名为 的存储桶中的文件my_bucket。
我已阅读有关如何在 Kubernetes pod 中安装存储桶的gcsfuse指南(https://github.com/maciekrb/gcs-fuse-sample ),还阅读了有关boto的信息(https://cloud.google.com/storage/docs ) /boto-plugin#streaming-transfers)用于将流传输到存储桶。
为了安装my_bucket在 中tmp/processed,我已将以下行添加到我的应用程序的部署文件 (YAML) 中:
lifecycle:
postStart:
exec:
command:
- gcsfuse
- -o
- nonempty
- my_bucket
- tmp/processed
preStop:
exec:
command:
- fusermount
- -u
- tmp/processed/
securityContext:
capabilities:
add:
- SYS_ADMIN
Run Code Online (Sandbox Code Playgroud)
我还没有使用过 boto,想也许只安装就足够了!但是,我的应用程序在尝试生成视频文件时出现输入/输出错误。
现在我的问题是,我是否需要同时使用gcsfuse和boto,还是只需将存储桶安装在我的 …
我有一个 NestJS API。我正在使用 TypeORM 连接到数据库。我的 API 是一个 Docker 容器。当我运行容器时,如果它无法连接到数据库,它会不断重试大约 10 次,然后退出。部分日志如下:
> nest start
[Nest] 31 - 09/23/2020, 8:39:14 PM [NestFactory] Starting Nest application...
[Nest] 31 - 09/23/2020, 8:39:14 PM [InstanceLoader] TypeOrmModule dependencies initialized +39ms
[Nest] 31 - 09/23/2020, 8:39:14 PM [InstanceLoader] AppModule dependencies initialized +1ms
[Nest] 31 - 09/23/2020, 8:39:14 PM [TypeOrmModule] Unable to connect to the database. Retrying (1)... +3ms
Error: getaddrinfo ENOTFOUND database database:5432
at GetAddrInfoReqWrap.onlookup [as oncomplete] (dns.js:56:26)
[Nest] 31 - 09/23/2020, 8:39:14 PM [TypeOrmModule] Unable …Run Code Online (Sandbox Code Playgroud) boto ×1
bucket ×1
celery ×1
gcsfuse ×1
kubernetes ×1
matlab ×1
nestjs ×1
plot ×1
python ×1
python-3.x ×1
redis ×1
redis-server ×1
typeorm ×1
typescript ×1