DataX-web安装使用教程

DataX-web安装使用教程

1. 环境准备

  • MySQL (5.5+)  必选,对应客户端可以选装, Linux服务上若安装mysql的客户端可以通过部署脚本快速初始化数据库
  • JDK (1.8.0_xxx)  必选
  • Python (2.x) 必选 (支持Python3需要修改替换datax/bin下面的三个python文件,替换文件在doc/datax-web/datax-python3下) ,主要用于调度执行底层DataX的启动脚本,默认的方式是以Java子进程方式执行DataX,用户可以选择以Python方式来做自定义的改造

2.DataX安装

2.1 下载DataX安装包

DataX详情介绍:https://github.com/alibaba/DataX/blob/master/introduction.md

DataX官网下载地址:https://github.com/alibaba/DataX

网盘地址链接:https://pan.baidu.com/s/1qxCi1k36mbHWfuxfMpTfxg 提取码: 1234

2.2 安装DataX

上传后进行解压并检测安装是否成功

# 下载上传后进行解压 tar -zxvf /opt/software/datax.tar.gz -C /opt/modules/ # 运行自检脚本 python /opt/modules/datax/bin/datax.py /opt/modules/datax/job/job.json

当输出下图结果代表安装成功

3.DataX-web安装

3.1 下载DataX-web安装包

DataX-web官网下载地址:https://github.com/WeiYe-Jing/datax-web

网盘地址链接: https://pan.baidu.com/s/1UmFMHdVamfOOo4KEezBkeQ  提取码: 1234

3.2 安装DataX-web

3.2.1 上传后进行解压

# 下载上传后进行解压 tar -zxvf /opt/software/datax-web-2.1.2.tar.gz -C /opt/modules/

3.2.2 在Mysql中创建存放datax-web任务信息的库表

创建数据库dataxweb

# 创建 dataxweb 数据库 create database dataxweb;

在dataxweb中执行datax_web.sql脚本 

脚本位置为:/opt/modules/datax-web-2.1.2/bin/db/datax_web.sql

3.2.3 执行安装datax-web命令

# 执行安装命令 sh /opt/modules/datax-web-2.1.2/bin/install.sh

安装过程中需要下载一些插件,输入“Y”下载即可

安装过程中需要输入数据库配置,输入提前准备好的Mysql相关信息:ip port username password databaseName

3.2.4 DataX-web中配置datax路径

/opt/modules/datax-web-2.1.2/modules/datax-executor/conf/application.yml

# vi 编辑文本 application.yml vi /opt/modules/datax-web-2.1.2/modules/datax-executor/conf/application.yml # 最后一行添加DataX执行命令 pypath: /opt/modules/datax/bin/datax.py

3.2.5 启动 DataX-web

# 启动datax-web sh /opt/modules/datax-web-2.1.2/bin/start-all.sh

4.DataX-web登录使用

4.1 登录DataX-web

登录地址:http://{你的ip}:9527/index.html用户名:admin密码:123456

登录后报如下错误:Unknown column 't.user_id' in 'field list'。

这个错误表示DataX Web的数据库表结构不完整。具体问题是:job_info表中缺少 user_id字段。

我们可以手动添加缺失字段

-- 检查表结构 DESC job_info; -- 添加缺失的user_id字段 ALTER TABLE job_info ADD COLUMN user_id VARCHAR(50) DEFAULT NULL COMMENT '用户ID' AFTER update_time; -- 验证字段是否添加成功 DESC job_info;

4.2 使用DataX-web

新建项目

创建DataX任务模板,以后创建的任务使用相关的模板。

创建数据库链接

下面开始配置数据同步任务,可以批量配置,也可单独配置,本次以单独配置为例

点击 “构建” 生成任务json,选择 “选择模版” 选择对应的调度模板绑定任务。

查看并执行任务

点击执行一次后便可手动执行,如需定时执行可将状态部分改成启动。

查看任务执行状况

查看任务报错信息

报错原因:

        DataX配置了总bps限速(1048576字节/秒 = 1MB/秒),同时配置了3个channel,但没有配置单个channel的bps值

修复:增大 byte ,修改核心配置文件:/opt/modules/datax/conf/core.json

将byte值从默认的1048576调整为更高的正整数5m(如5242880),并确保record不为负数(如设为1000或删除record字段)。

# 修改 byte record 参数 "transport": { "channel": { "class": "com.alibaba.datax.core.transport.channel.memory.MemoryChannel", "speed": { "byte": 5242880,// 修改为正整数(如5MB)JSON不支持注释 "record": 1000 // 确保record值不为负数(可选)JSON不支持注释 }, "flowControlInterval": 20, "capacity": 512, "byteCapacity": 67108864 }, "exchanger": { "class": "com.alibaba.datax.core.plugin.BufferedRecordExchanger", "bufferSize": 32 } },

修改完配置再次执行

Read more

【Java后端向前端推送消息】

【Java后端向前端推送消息】

1、WebSocketConfig配置类 import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.web.socket.config.annotation.EnableWebSocket;import org.springframework.web.socket.server.standard.ServerEndpointExporter; @Configuration @EnableWebSocket publicclassWebSocketConfig{ @Bean public ServerEndpointExporter serverEndpointExporter(){returnnewServerEndpointExporter();}} 2、WebSocket消息发送接收 import lombok.extern.slf4j.Slf4j;import

前端代码质量保证:让你的代码更可靠

前端代码质量保证:让你的代码更可靠 毒舌时刻 代码质量?听起来就像是前端工程师为了显得自己很专业而特意搞的一套复杂流程。你以为随便写几个测试就能保证代码质量?别做梦了!到时候你会发现,测试代码比业务代码还多,维护起来比业务代码还麻烦。 你以为ESLint能解决所有问题?别天真了!ESLint只能检查代码风格,无法检查逻辑错误。还有那些所谓的代码质量工具,看起来高大上,用起来却各种问题。 为什么你需要这个 1. 减少错误:代码质量保证可以帮助你发现和修复代码中的错误,减少生产环境中的问题。 2. 提高可维护性:高质量的代码更容易理解和维护,减少后期的维护成本。 3. 促进团队协作:统一的代码质量标准可以便于团队成员之间的协作,减少沟通成本。 4. 提高开发效率:高质量的代码可以减少调试和修复错误的时间,提高开发效率。 5. 提升代码安全性:代码质量保证可以帮助你发现和修复安全漏洞,提升代码的安全性。 反面教材 // 这是一个典型的代码质量问题示例 // 1. 代码风格不一致 function getUser(id) { return fetch(`/api/

AI写代码工具哪个好用?资深码农实测,看这篇就够!

AI写代码工具哪个好用?资深码农实测,看这篇就够!

身为一个老程序员,我亲身经历了从纯手敲代码到AI智能辅助的演变。现在,如果一个程序员还不懂得利用AI工具,那无异于放弃了“第二次工业革命”。市场上的AI编程工具层出不穷,但究竟哪款才适合你?今天,我就为大家深度评测5款我亲自使用过且认为非常好用的工具,帮你精准避坑,高效提升。 1. Lynx:对话式应用生成器,快速构建原型的神器 Lynx 是一款相对较新但理念非常前沿的对话式AI编程工具。它的目标不仅仅是生成代码片段,而是让你通过自然语言对话,直接创建出可运行的全栈Web应用。 * 核心优势: * 全栈生成: 你只需要用语言描述你想要的应用功能,比如“创建一个带有用户登录和任务列表的待办事项应用”,Lynx 会帮你生成前端、后端和数据库结构,并提供可访问的URL。 * 对话式开发: 整个开发过程就像在与一个资深技术合伙人对话,你可以随时提出修改需求、添加功能,它会实时响应并更新代码。 * 降低门槛: 对于初学者、产品经理或需要快速验证想法的开发者来说,Lynx 能极大地缩短从想法到产品原型的路径。 * 适用场景: 快速构建MVP(最小可行产品)、学习全栈开

微信终于官宣!OpenClaw(龙虾)正式接入,你的微信里多了一个AI管家

微信终于官宣!OpenClaw(龙虾)正式接入,你的微信里多了一个AI管家 就在昨天,微信放出了一个让科技圈沸腾的消息:微信正式推出「ClawBot」插件,支持接入开源AI智能体OpenClaw(俗称“龙虾”) 。 这意味着,你再也不需要冒着封号的风险使用非官方插件,现在可以直接在微信聊天界面里召唤你的“龙虾”替你干活了。 什么是“龙虾”? 首先科普一下,为什么大家管OpenClaw叫“龙虾”?因为它的图标是红色的,形似龙虾,所以被网友们亲切地称为“龙虾”。OpenClaw是一款实现“认知、执行、记忆”闭环的开源AI框架,简单来说,它能让AI真正“长出手脚”,自主执行文件管理、邮件收发、数据处理等复杂任务。 而微信这次推出的ClawBot插件,就是帮你用微信连接个人龙虾的聊天入口——相当于你现在能跟你的“虾”成为微信好友了。 如何接入? 想要在微信里玩转龙虾,操作非常简单,只需两步: 第一步:启用微信ClawBot插件 * 将微信更新到