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

删除了不需要的空格