反馈已提交

网络繁忙

WebSocket输入

  • 文档创建者:Wendy123456
  • 历史版本:10
  • 最近更新:Richard.Guo 于 2025-08-29
  • icon提示:

    产品注册版本为「v5.0共创版」时,才能使用数据开发-实时任务:

    1) 如需申请免费试用或增购功能点,请填写链接:实时任务意向使用申请表

    2) 如需了解更多实时任务详细信息,可联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。

    1. 概述

    1.1 版本

    FineDataLink 版本功能变动
    5.0.0.1-
    5.0.1.5实时任务中若使用「WebSocket 输入节点,不能再使用 分组汇总(实时任务)Flink SQL数据关联(多个实时数据源进行关联)

    1.2 应用场景

    物联网数据是通过 WebSocket 协议开放的,希望实时任务读取 WebSocket 数据。

    1.3 功能简介

    数据开发-实时任务中,新增WebSocket 输入」算子,支持读取 WebSocket 数据。如下图所示:

    18.png

    1.4 功能限制

    5.0.1.5 及之后版本,实时任务中若使用「WebSocket 输入节点,不能再使用 分组汇总(实时任务)Flink SQL数据关联(多个实时数据源进行关联)。

    2. 功能说明

    1)需要先配置 WebSocket数据连接

    2)「WebSocket 输入」算子界面如下图所示:

    18.png

    设置项
    说明
    数据源

    WebSocket 类型的数据连接

    输出字段

    配置读取 WebSocket 消息中哪些信息传输给下游算

    • 消息内容(message):消息的实际内容

    • 对于不同数据格式的value(json、键值对、Avro等),统一都转换为文本格式

    同步类型仅增量同步,不可自定义
    增量同步起点任务启动时间,不可自定义
    样本设置只支持「手动配置」

    3. 操作步骤

    实时任务中读取 WebSocket 数据,经过 JSON 解析后,输出到数据库表中。

    注:需要先配置 WebSocket数据连接

    3.1 WebSocket 输入

    1)进入 FineDataLink 工程,点击「数据开发>实时任务」,创建实时任务。如下图所示:

    2.png

    2)进入编辑页面后,拖入WebSocket 输入」算子,读取 WebSocket 数据。如下图所示:

    3.png

    点击「数据预览,如下图所示:

    6.png

    3.2 JSON 解析

    拖入「JSON 解析」算子,解析 WebSocket 数据。如下图所示:

    7.png

    点击「数据预览,如下图所示:

    8.png

    3.3 数据输出

    拖入「DB表输出」算子,将处理后的数据输出。如下图所示:

    1748400996117257.png

    3.4 启动任务

    点击右上角的「启动按钮,启动实时任务。启动后界面如下图所示:

    10.png





    附件列表


    主题: 数据开发-实时任务
    • 有帮助
    • 没帮助
    • 只是浏览
    中文(简体)

    鼠标选中内容,快速反馈问题

    鼠标选中存在疑惑的内容,即可快速反馈问题,我们将会跟进处理。

    不再提示

    10s后关闭



    AI

    联系我们
    在线支持
    获取专业技术支持,快速帮助您解决问题
    工作日9:00-12:00,13:30-17:30在线
    页面反馈
    针对当前网页的建议、问题反馈
    售前咨询
    采购需求/获取报价/预约演示
    或拨打: 400-811-8890 转1
    qr
    热线电话
    咨询/故障救援热线:400-811-8890转2
    总裁办24H投诉:17312781526
    提交页面反馈
    仅适用于当前网页的意见收集,帆软产品问题请在 问答板块提问前往服务平台 获取技术支持