Я пытаюсь обработать кучу текста с помощью сервиса google nlp через очередь в сельдерее.Я установил учетные данные в терминале
export GOOGLE_APPLICATION_CREDENTIALS="/path/key.json"
, а затем попытался запросить службу Google в очереди
@app.task
def classifyItem(item):
id = item['catalog_id']+item['sku']
logger.info(f"received item for classification {id}")
document = language.types.Document(content=item["description"],type=language.enums.Document.Type.PLAIN_TEXT)
features = {
'extract_syntax': True,
'extract_entities': True,
'extract_document_sentiment': True,
'extract_entity_sentiment': True,
'classify_text': False
}
response = language_client.annotate_text(document=document,features=features)
logger.info("item processed")
return "processed"
Я получил бы подтверждение, что элемент былполучен очередью, но он никогда не выходит за рамки этого.Однако выполнение кода отдельно от очереди получит ответ.
Я предполагаю, что это как-то связано с переменными среды, но я не уверен, что именно мне нужно изучить.Буду очень признателен за некоторые советы по этому вопросу.