Как использовать облачный источник рынка продаж в операторе AppFlow в Airflow? ⇐ Python
-
Гость
Как использовать облачный источник рынка продаж в операторе AppFlow в Airflow?
Я извлекаю данные из отдела продаж в корзину AWS S3 с помощью Airflow AppFlowOperator. Чтобы извлечь данные, используя Salesforce в качестве источника, я просто использую:
task_campaign_dump = AppflowRunOperator( Task_id="campaign_dump", источник="Salesforce", даг = даг, имя_потока=имя_потока) Все работает правильно. Однако когда я попытался запустить поток, в качестве источника которого используется SalesForce Market Cloud, приведенный выше код не сработал. Я полагаю, что мне следует изменить имя источника, но в документации Airflow указано, что в качестве значений аргумента источника принимаются только Salesforce и Zendesk.
Есть ли способ запустить поток AppFlow с использованием облачного источника Salesforce Market в Airflow?
Я извлекаю данные из отдела продаж в корзину AWS S3 с помощью Airflow AppFlowOperator. Чтобы извлечь данные, используя Salesforce в качестве источника, я просто использую:
task_campaign_dump = AppflowRunOperator( Task_id="campaign_dump", источник="Salesforce", даг = даг, имя_потока=имя_потока) Все работает правильно. Однако когда я попытался запустить поток, в качестве источника которого используется SalesForce Market Cloud, приведенный выше код не сработал. Я полагаю, что мне следует изменить имя источника, но в документации Airflow указано, что в качестве значений аргумента источника принимаются только Salesforce и Zendesk.
Есть ли способ запустить поток AppFlow с использованием облачного источника Salesforce Market в Airflow?
