Как использовать облачный источник рынка продаж в операторе AppFlow в Airflow? ⇐ Python

[Гость]

Я извлекаю данные из отдела продаж в корзину AWS S3 с помощью Airflow AppFlowOperator. Чтобы извлечь данные, используя Salesforce в качестве источника, я просто использую:

task_campaign_dump = AppflowRunOperator( Task_id="campaign_dump", источник="Salesforce", даг = даг, имя_потока=имя_потока) Все работает правильно. Однако когда я попытался запустить поток, в качестве источника которого используется SalesForce Market Cloud, приведенный выше код не сработал. Я полагаю, что мне следует изменить имя источника, но в документации Airflow указано, что в качестве значений аргумента источника принимаются только Salesforce и Zendesk.

Есть ли способ запустить поток AppFlow с использованием облачного источника Salesforce Market в Airflow?