Talend可以使用Java代码来处理数据转换。以下是一个简单的例子:
假设你有一个包含以下列的CSV文件:
Name,Age,Gender
John,25,Male
Jane,30,Female
你需要将它转换为以下格式:
{"records": [{"name": "John","age": 25,"gender": "Male"},{"name": "Jane","age": 30,"gender": "Female"}] }
你可以使用以下步骤来完成此转换:
-
创建一个Talend Job,并添加一个
tFileInputDelimited
组件来读取CSV文件。 -
添加一个
tJavaRow
组件,将其连接到tFileInputDelimited
组件。 -
在tJavaRow组件中使用以下代码:
-
// 获取输入行 String name = input_row.Name; int age = Integer.parseInt(input_row.Age); String gender = input_row.Gender;// 将数据格式化为JSON字符串 String json = String.format("{\"name\": \"%s\", \"age\": %d, \"gender\": \"%s\"}", name, age, gender);// 将JSON字符串写入上下文 output_row.json = json;
-
添加一个
tAggregateRow
组件,将其连接到tJavaRow
组件。在tAggregateRow
组件中,设置Aggregate type
为First
,并创建一个名为records
的新列。 -
在
tAggregateRow
组件中,使用以下代码将多行数据聚合为一个JSON对象:
// 创建一个空的JSON对象 JSONObject jsonObject = new JSONObject(); JSONArray recordsArray = new JSONArray();// 循环遍历每行数据 for (int i = 0; i < input_rows.size(); i++) {// 将每行数据转换为JSON对象JSONObject record = new JSONObject(input_rows.get(i).json);// 添加到records数组recordsArray.put(record); }// 将records数组添加到JSON对象 jsonObject.put("records", recordsArray);// 将JSON对象写入上下文 output_row.json = jsonObject.toString();
-
添加一个
tFileOutputJSON
组件,将其连接到tAggregateRow
组件。设置目标文件路径。 -
运行作业。在目标文件中,你会得到以下JSON:
{"records": [{"name": "John","age": 25,"gender": "Male"},{"name": "Jane","age": 30,"gender": "Female"}] }
这只是一个简单的例子。你可以在tJavaRow组件中使用更复杂的Java代码来处理数据转换,并使用其他组件来完成不同的任务。