CDAP工具中的python变换

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,
         })

删除不需要的空格

​