python 在 CDAP 工具中转换

Question

我试图在 CDAP 中创建一个 python 转换，但我遇到了以下问题。请您查看并尽快通知我更新。

请找到以下问题，用例供您参考。

问题：配置阶段 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,
         })

删除了不需要的空格

python 在 CDAP 工具中转换

python transform in CDAP Tool

python

etl

cdap