1

環境

OS:Debian10/11
WEBサーバー:nginx
フレームワーク:Django
キューイング:celery
DB:postgreSQL
ブローカー:redis

celeryd,celerybeatがデーモン化されています。

目的

Debian10->11への移植

状況

django_celery_resultsでDBへの出力を行っています。
Debain11ではスケジュールされたタスクが機能していないようです。

データベーステーブルの状態を示します。
Debian11では、以下のテーブルが存在しています。
django_celery_results_chordcounter
django_celery_results_groupresult

これらのテーブルはいつ生成されて、どのような機能があるのでしょうか?
正しく機能していれば、実行後に消去されるテーブルでしょうか?

Debian10

postgres=# \dt
                      List of relations
 Schema |               Name               | Type  |  Owner
--------+----------------------------------+-------+----------
 public | auth_group                       | table | postgres
 ...
 public | django_admin_log                 | table | postgres
 public | django_celery_results_taskresult | table | postgres
 public | django_content_type              | table | postgres
 public | django_migrations                | table | postgres
 public | django_session                   | table | postgres
 ...

Debian11

postgres=# \dt
                      List of relations
 Schema |               Name                 | Type  |  Owner
--------+------------------------------------+-------+----------
 public | auth_group                         | table | postgres
 ...
 public | django_admin_log                   | table | postgres
 public | django_celery_results_chordcounter | table | postgres
 public | django_celery_results_groupresult  | table | postgres
 public | django_celery_results_taskresult   | table | postgres
 public | django_content_type                | table | postgres
 public | django_migrations                  | table | postgres
 public | django_session                     | table | postgres
 ...
 

補足情報

ディレクトリツリー

./django
├── manage.py
├── project
│   ├── __init__.py
│   ├── app_static
│   │   └── ...
│   ├── asgi.py
│   ├── celery.py
│   ├── celeryconfig.py
│   ├── manager
│   │   ├── __init__.py
│   │   ├── admin.py
│   │   ├── api_urls.py
│   │   ├── apps.py
│   │   ├── consumers.py
│   │   ├── debouce.py
│   │   ├── middleware.py
│   │   ├── migrations
│   │   │   ├── 0001_initial.py

│   │   ├── models.py
│   │   ├── routing.py
│   │   ├── serializers.py
│   │   ├── setup_util.py
│   │   ├── tasks.py
│   │   ├── tests.py
│   │   ├── throttle.py
│   │   └── views.py
│   ├── routing.py
│   ├── settings.py
│   ├── templates

│   ├── urls.py
│   └── wsgi.py
├── proxy


├── uwsgi
│   ├── django_app.ini
│   └── websocket.ini


django project/settings.py

INSTALLED_APPS = [
    'project.manager.apps.ManagerConfig',
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'rest_framework',
    'corsheaders',
    'channels',
    'django_celery_results',
]

CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels_redis.core.RedisChannelLayer',
        'CONFIG': {
            "hosts": [('localhost', 6379)],
        },
    },
}

django project/celery.py

from __future__ import absolute_import

import os

from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')

app = Celery('project')
app.config_from_object('project.celeryconfig')
app.autodiscover_tasks()

django project/celeryconfig.py

from __future__ import absolute_import

broker_url = 'redis://localhost:6379'
result_backend = 'redis://localhost:6379'
accept_content = ['application/json']
task_serializer = 'json'
result_serializer = 'json'
timezone = 'Asia/Tokyo'

imports = (
    'project.manager.tasks',
)

1 件の回答 1

1

※あくまで「いつ生成されるか」に対してのみ回答します。

ソースコードのリポジトリ を覗いてみると、migrations ディレクトリの下にあるファイルで作成されるように見えます。
help_text= で指定されている文字列が内容のヒントになりそうです。

0008_chordcounter.py (24行目)

                    help_text='Celery ID for the Chord header group',

0009_groupresult.py (34行目)

                    help_text='Celery ID for the Group that was run',
1
  • ありがとうございます。Debian10、Debian11において、Python,Django,Celeryのバージョンも更新されており、質問内容のテーブルの作成有無はそこらへんの問題かもしれません。タスクが機能しないのは、Celeryグローバルオプションの扱い方がバージョンで改変されていたからでした。 Commented 3月15日 5:13

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。