Я использую приведенный ниже код, чтобы получить некоторую информацию в записной книжке Azure Databricks, но runOutput не появляется даже после успешного завершения действия записной книжки.
Код, который я использовал.
import json
dbutils.notebook.exit(json.dumps({
"num_records" : dest_count,
"source_table_name" : table_name
}))
Записная книжка Databricks завершила работу правильно, но активность записной книжки не показывает runOutput.
Может кто-нибудь, пожалуйста, помогите мне, что здесь не так?
Да, он должен прийти, но мне runOuput почему-то не приходит. @РакешГовиндула. Но, чтобы не блокировать свою работу, я нашел альтернативный способ получить это.
Подумайте о том, чтобы опубликовать свой альтернативный способ в качестве ответа для других членов сообщества.
Когда я попробовал вышеописанное в своей среде, у меня все работает нормально.
Это мои конфигурации связанной службы.
Результат:
Я предлагаю вам попробовать шаги по устранению неполадок, такие как замена ноутбука и изменение рабочей области Databricks на новую или использование существующего кластера в связанной службе.
Если все равно выдает то же самое, то лучше поднять тикет поддержки по вашей проблеме.
Я не уверен, почему он не заполняет runOuput. По сути, мне нужно получить количество записей, которые он отправляет в Azure Synapse, поэтому я использовал действие поиска, чтобы получить количество записей в этой таблице.
У меня это работает нормально, когда я пытался использовать существующий кластер в своей среде. i.imgur.com/8bek0HS.png. Попробуйте сохранить его в строковой переменной в ADF с помощью
@string(activity('Notebook1').output.runOutput)
и посмотрите, сможете ли вы его получить.