Создать конвейерный запуск на фабрике данных v2 с использованием rest api

#azure-data-factory #azure-data-factory-2

#azure-data-factory

Вопрос:

Я использую NodeJS для создания конвейерного запуска на фабрике данных v2, и мне нужно передать два параметра в теле. При этом параметры в конвейер не передаются. Конвейер запущен, но параметры, которые я передаю в формате JSO, не принимаются конвейером

Создание константы options, которую я использую в своем запросе:

     const options = {
            hostname: 'management.azure.com',
            port: 443,
            path: '/subscriptions/<subscriptionId>/resourceGroups/<resourceGroup>/providers/Microsoft.DataFactory/factories/<datafactoryName>/pipelines/<pipelineName>/createRun?api-version=2018-06-01',
            method: 'POST',
            body: req.body,
            headers: {
                'Authorization': 'Bearer <token>',
                'Content-Type': 'application/json'
            }
        };
  

Запрос.body выглядит следующим образом:

    {
     “inputpath”: “input file location”,
     “outputpath”: “output file location”
   }
  

Последний запрос к ADFv2 Rest API:

  var req = https.request(options, result => {
            result.on('data', (chunk) => {
                res.send(chunk);
            });
        })
        req.on('data', (data) => {
        });
  

Комментарии:

1. Пожалуйста, предоставьте подробный код nodejs, который запускает ваш конвейер и передает параметры.

2. @JayGong добавил примеры кода

3. Как вы обнаружили, что параметры не приняты? Правильна ли ваша полезная нагрузка конвейера? Вы пробовали запускать это в пользовательском интерфейсе?

4. @FangLiu: Я проверил это при запуске конвейера ADF. Когда я запускаю конвейер из пользовательского интерфейса с параметрами, конвейер работает просто отлично.

5. Вы могли бы нажать F12, чтобы открыть режим отладки браузера, а затем перейти на вкладку сеть. Вы узнаете, какую полезную нагрузку отправляет пользовательский интерфейс, когда вы нажимаете кнопку запуска now. Надеюсь, вы могли бы помочь вам проверить полезную нагрузку api.