我有一个通过API POST请求将对象id添加到队列的django视图。然后,我有一个芹菜任务,它将id从队列中取出并进行一些处理。有时,芹菜任务抛出一个错误,表示对象不存在。我给视图添加了一个5秒的延迟,我再也不会得到那个错误了。
View:
def create(self, request):
user = request.user
serializer = UnpredictedSentenceSerializer(data=request.data)
if serializer.is_valid():
saved_raw_text = UnpredictedSentence.objects.create(
raw_text=serializer.data['raw_text'],
user=user)
prediction.apply_async(
args=[saved_raw_text.pk],
countdown=5
)
print(saved_raw_text.pk)
return Response(status=status.HTTP_200_OK)
else:
return Response(
serializer.errors, status=status.HTTP_400_BAD_REQUEST)
Task:
@task()
def prediction(id):
print(id)
print(type(id))
UnpredictedSentence.objects.get(pk=id)
try:
un_sent = UnpredictedSentence.objects.get(pk=id)
except UnpredictedSentence.DoesNotExist:
un_sent = None
if un_sent:
print(type(un_sent.raw_text))
text = json.loads(un_sent.raw_text)
results = kudos.main(text['raw_text'])
PredictedSentence.objects.create(
cleaned_text=results['cleaned_text'],
raw_text=results['raw_text'],
sentiment=results['sentiment'],
user=un_sent.user)
print(results)
几乎可以肯定是事务问题。由于事务隔离,在事务提交之前,其他进程不会看到已创建的对象,事务提交发生在请求结束时。5秒的延迟给了它足够的时间。