Json值抽取

功能介绍

该组件完成json字符串中的信息抽取，按照用户给定的Path 抓取出相应的信息。该组件支持多Path抽取。

参数说明

名称 中文名称 描述 类型 是否必须？ 默认值
jsonPath Json 路径数组 用来指定 Json 抽取的内容。 String[] ✓
skipFailed 是否跳过错误 当遇到抽取值为null 时是否跳过 boolean false
selectedCol 选中的列名 计算列对应的列名 String ✓
reservedCols 算法保留列名 算法保留列 String[] null
outputCols 输出结果列列名数组 输出结果列列名数组，必选 String[] ✓

脚本示例

运行脚本

  1. import numpy as np
  2. import pandas as pd
  3. data = np.array([
  4.     ["{a:boy,b:{b1:1,b2:2}}"],
  5.     ["{a:girl,b:{b1:1,b2:2}}"]])
  6. df = pd.DataFrame({"str": data[:, 0]})
  8. streamData = dataframeToOperator(df, schemaStr='str string', op_type='stream')
  10. JsonValueStreamOp().setJsonPath(["$.a","$.b.b1"]).setSelectedCol("str").setOutputCols(["f0","f1"]).linkFrom(streamData).print()
  11. StreamOperator.execute()

运行结果

str f0 f1
{a:boy,b:{b1:1,b2:2}} boy 1
{a:girl,b:{b1:1,b2:2}} girl 1