开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

有没有哪位在flink sql中使用 过string转json_array的函数?

有没有哪位在flink sql中使用 过string转json_array的函数?我现在的场景是从kafka中接入数据写入数据库中,kafka中的数据结构为:{"uuid":"xxxx","body_data":"[{"fild1":123,"fild2":234}]"},由于body_data是json字符串,shcema为ARRAY<ROW<field1 INT, field2 INT>>>,现在需要将array拆开每个ROW<field1 INT, field2 INT>为1行放入数据库中

展开
收起
圆葱猪肉包 2023-03-27 14:24:22 1182 0
2 条回答
写回答
取消 提交回答
  • 767bfc80df38f5ee6d1e928c9940e9d6.jpg 试下这些函数代捷此回答整理自钉群“【③群】Apache Flink China

    2023-03-28 11:06:19
    赞同 展开评论 打赏
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    使用 Flink SQL 中的内置函数 from_json 和 explode 来实现将 JSON 字符串转换为数组并将其拆分成单独的行。

    SELECT uuid, field1, field2
    FROM (
      SELECT uuid, from_json(body_data, ARRAY<ROW<field1 INT, field2 INT>>) as data
      FROM kafka_topic
    ) t, LATERAL TABLE(explode(data)) as exploded_table(field1, field2)
    
    

    使用 from_json 函数将 body_data 字段中的 JSON 字符串转换为数组。然后,使用 LATERAL TABLE 和 explode 函数将数组拆分成单独的行,并将每个 ROW<field1 INT, field2 INT> 的值作为单独的列返回。

    2023-03-27 14:54:37
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    SQL Server 2017 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载