django会立即创建对象吗?



我有一个通过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秒的延迟给了它足够的时间。

相关内容

  • 没有找到相关文章

最新更新