Обновление поискового индекса Haystack с помощью Django + Celery

Question

В моем проекте Django я использую Celery. Я переключил команду из crontab, чтобы она выполнялась периодически, и она хорошо работает, но это просто вызов метода в модели. Можно ли обновить индекс Хейстек из периодической задачи? Кто-нибудь делал это?

/manage.py update_index

Это команда для обновления индекса из документации Haystack, но я не уверен, как вызвать это из задачи.

Answer 1

Самый простой способ сделать это, вероятно, состоит в том, чтобы запустить команду управления непосредственно из python и запустить ее в своей задаче

from haystack.management.commands import update_index
update_index.Command().handle()

Answer 2

Что касается бета-версии haystack версии 2.0.0, этот код должен работать:

from haystack.management.commands import update_index
update_index.Command().handle(using='default')

Answer 3

Кроме того, начиная со 2-й версии стога сена, вы можете вызывать пересбор индекса из python как

from haystack.management.commands import update_index, rebuild_index
rebuild_index.Command().handle(interactive=False)

Где " интерактивный " не позволит стогу сена задавать вопрос, если вы действительно хотите перестроить индекс. Это эквивалентно параметру командной строки --no-input.

Если вы используете xapian в качестве бэкэнда FTS, помните, что многопоточное обновление индекса приведет к блокировке записи в БД. Итак, решение с пакетом celery-haystack пытается распространить обновление индекса на несколько рабочих (несколько потоков), что приводит к блокировке с помощью xapian.

Answer 4

https://github.com/django-haystack/celery-haystack

Я считаю этот пакет отличным и простым подключаемым приложением для индексации стога сена через сельдерей. Я использовал его в нескольких проектах.