RethinkDB Python Рекурсивный фильтр документов

Question

Попытка сделать рекурсивный запрос к фильтру в RethinkDB с помощью оболочки Python. У меня много проблем, чтобы заставить его работать.

Перепробовал много вариантов запроса, но безрезультатно. По сути, я пытаюсь найти строки, которые не имеют документа, вложенного в label с определенным идентификатором пользователя.

Говоря простым языком: если текущий пользователь уже пометил этот пример, больше не возвращайте его.

Мой нерабочий запрос:

open_tasks = rdbt \
    .order_by(index=r.desc('labels_completed')) \
    .filter(r.row['locked'] == False) \
    .filter(lambda task:
            task['labels']['user_id'] != current_user.id) \
    .limit(qty) \
    .run(conn)

Мой набор данных

[
    {
        "id": "e54893b4-b1d0-49c5-b6aa-9aa9e7d2b73b",
        "image": "https://dl.dropboxusercontent.com/u/5822/crowdlabeler/ABLXOTODWJKTXECYZTST.jpg",
        "labels": [
            {
                "account_qty_labeled": 54,
                "account_signup_date": "Tue Aug 04 2015 10:12:25 GMT-04:00",
                "compensation": 0.01,
                "dataset_id": 144,
                "label": {
                    "$$hashKey": "object:45",
                    "answer": "Yes",
                    "selected": true
                },
                "label_duration_sec": 3,
                "labeled_at": "Wed Aug 05 2015 16:26:04 GMT-05:00",
                "sess_duration_sec": 3,
                "sess_qty_labeled": 0,
                "user_id": 1
            }
        ],
        "labels_completed": 0,
        "locked": false,
        "text": "Lorem ipsum dolor sit amet, consectetur adipisicing elit. Cupiditate adipisci vero minus laudantium reprehenderit exercitationem eius, suscipit facilis laboriosam consequuntur, eligendi quis mollitia excepturi deserunt dicta, dolorem quaerat pariatur provident sint explicabo. Magnam possimus dolorum beatae quidem excepturi quibusdam dolore reprehenderit accusantium quae ad libero, voluptatum laborum, incidunt, voluptate reiciendis."
    },
    {
        "id": "9f08869e-79fd-49c0-a184-c43d2a1c95cf",
        "image": "https://dl.dropboxusercontent.com/u/5822/crowdlabeler/ACSGHDYECQWQXDHIOBYC.jpg",
        "labels": [],
        "labels_completed": 0,
        "locked": false,
        "text": "Lorem ipsum dolor sit amet, consectetur adipisicing elit. Cupiditate adipisci vero minus laudantium reprehenderit exercitationem eius, suscipit facilis laboriosam consequuntur, eligendi quis mollitia excepturi deserunt dicta, dolorem quaerat pariatur provident sint explicabo. Magnam possimus dolorum beatae quidem excepturi quibusdam dolore reprehenderit accusantium quae ad libero, voluptatum laborum, incidunt, voluptate reiciendis."
    },
    {
        "id": "9fba0a39-4cfd-4a97-b48f-e8bf2b0d46c5",
        "image": "https://dl.dropboxusercontent.com/u/5822/crowdlabeler/ADMNIUYKUHAIOHMAFXBK.jpg",
        "labels": [],
        "labels_completed": 0,
        "locked": false,
        "text": "Lorem ipsum dolor sit amet, consectetur adipisicing elit. Cupiditate adipisci vero minus laudantium reprehenderit exercitationem eius, suscipit facilis laboriosam consequuntur, eligendi quis mollitia excepturi deserunt dicta, dolorem quaerat pariatur provident sint explicabo. Magnam possimus dolorum beatae quidem excepturi quibusdam dolore reprehenderit accusantium quae ad libero, voluptatum laborum, incidunt, voluptate reiciendis."
    }
]

Спасибо за помощь!

Answer 1

Это было сложно, но решение оказалось двойным.

Небольшое изменение схемы при сохранении, а затем с использованием RethinkDB contains метод.

Вот модифицированный запрос, который работает хорошо.

open_tasks = rdbt \
    .order_by(index=r.desc('labels_completed')) \
    .filter(r.row['locked'] == False) \
    .filter(lambda task:
            r.not_(task['labeler_ids'].contains(current_user.id))) \
    .limit(qty) \
    .run(conn)