该ImportError: No module named postgresql
错误是由于您使用的无效的前缀celery_result_backend
。将数据库用作Celery后端时,连接URL必须以前缀db+
。参见https://docs.celeryproject.org/en/stable/userguide/configuration.html#conf- database-result- backend
因此,请替换:
celery_result_backend = postgresql+psycopg2://username:password@192.168.1.2:5432/airflow
与类似:
celery_result_backend = db+postgresql://username:password@192.168.1.2:5432/airflow