【发布时间】:2020-08-31 14:02:15
【问题描述】:
我有这样的芹菜任务
from celery import shared_task
@shared_task
def send_to_sap(user_id):
user = User.objects.get(pk=user_id)
if settings.SYNCHRONIZATION:
response = requests.post(
settings.SOME_URL,
json={}
)
我想从视图中以异步模式执行它,我正在尝试这样做
from tasks import send_to_sap
def send_to_sap(request, pk):
# some logic...
if serializer.is_valid():
serializer.save()
send_to_sap.apply_async(kwargs={'user_id': pk})
return Response(status=status.HTTP_200_OK)
【问题讨论】: