Проблема с Mongo Watch Cursor с конвейером агрегации - PullRequest
0 голосов
/ 22 марта 2019

У меня есть указатель Mongo DB Watch, который получает из потока те документы, которые имеют order_status как 'fail', 'доставлен' или 'отменен'. Когда я выполняюсь, всегда возникают ошибки при произнесении имени поля, к которому я обращаюсь. Но без конвейера курсор работает нормально. Прошу процитировать ошибку, которую я совершаю. Ниже приведен фрагмент кода. order_status является независимым полем и не является частью массива или объекта.

   Pipeline = [{'$match':{'fullDocument.order_status':{'$in': 
   ['failed','cancelled','delivered']}}}]

    try:
        cursor = collection_ptr.watch(full_document='updateLookup', resume_after=resume_token,pipeline=Pipeline)
    except Exception as e:
         print(str(e))

Управление программой всегда происходит, кроме блокировки, и печатает ниже. 'статус заказа'. Pymongo версия 3.7.2

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...