Преобразование Python в CDAP Tool

Question

Я пытаюсь создать преобразование Python в CDAP, где я сталкиваюсь с проблемой ниже. Просим Вас проверить и сообщить мне обновление как можно скорее.

Пожалуйста, найдите нижеприведенную проблему, используйте пример для справки.

Проблема: настройка стадии python является нулевой.

Вариант использования: пользователь импортирует данные из MYSQL, а при преобразовании Python мы используем пример сценария и экспортируем данные в файл.

Пожалуйста, проверьте прикрепленный скриншот для справки.

  def transform(record, emitter, context):
            if (record['actor_id'] > 0):
                  tax = record['actor_id'] * 10
                   emitter.emit({
                     'actor_id': record['actor_id'],
                     'tax': tax,
                     'total': record['subtotal'] + tax,
                   })

actor_id преобразуется и обрабатывается на следующем этапе.

Answer 1

Замените свой код на

def transform(record, emitter, context):
      if (record['actor_id'] > 0):
        tax = record['actor_id'] * 10
        emitter.emit({
           'actor_id': record['actor_id'],
           'tax': tax,
           'total': record['subtotal'] + tax,
         })

удалены ненужные места