Параллельная обработка с асинхронными вызовами для API OpeanAI
Я написал приложение для получения новостей из определенных rss-лент и выполнения некоторых процессов над ними с использованием chatgpt api.
Я запланировал получение новостей и их обработку каждую минуту, после чего возникла проблема. Каждую минуту, допустим, скрипт получает 300 новостей, и chatgpt api пытается обработать все эти 300 новостей. Через минуту, не завершив предыдущие 300, он начинает обрабатывать следующую партию, поэтому автоматически не может завершить предыдущую. Мне нужно, чтобы скрипт по-прежнему получал новости каждую минуту и, как только они будут получены, начинал их обрабатывать.
Вся обработка каждой новостной статьи chatgpt api будет происходить одновременно, и добавление новых статей не будет прерывать предыдущие. Например, допустим, было получено 300 новостей, все они будут обработаны chatgpt в одно и то же время по отдельности.
Я обновил свой код в соответствии с документацией OpenAI, но по какой-то причине не могу заставить его работать.
Я продолжаю получать эту ошибку, несмотря на то, что делаю все в соответствии с документацией OpenAI:
Вот ошибка, которую я получаю:
jango.core.exceptions.SynchronousOnlyOperation: You cannot call this from an async context - use a thread or sync_to_async.
Полная информация:
Как я могу исправить эту проблему?
Я пытался проверить код на наличие ошибок, но не смог определить, что именно не так