Skip to content

Latest commit

 

History

History
197 lines (136 loc) · 7.24 KB

README_zh-CN.md

File metadata and controls

197 lines (136 loc) · 7.24 KB
Raw

go-etl

LICENSE Language Build Go Report Card GitHub release GitHub release date Coverage Status GoDoc

English | 简体中文

go-etl是一个集数据源抽取，转化，加载的工具集，提供强大的数据同步能力。

go-etl将提供的etl能力如下：

  1. 主流数据库的数据抽取以及数据加载的能力，在storage包中实现
  2. 类二维表的数据流的数据抽取以及数据加载的能力，在stream包中实现
  3. 类似datax的数据同步能力，在datax包中实现

鉴于本人实在精力有限，欢迎大家来提交issue或者加QQ群185188648来讨论go-etl，让我们一起进步!

数据同步工具

本数据数据同步工具以下数据源的同步能力

类型 数据源 Reader（读） Writer(写) 文档
关系型数据库 MySQL/Mariadb/Tidb √ √ 读、写
Postgres/Greenplum √ √ 读、写
DB2 LUW √ √ 读、写
SQL Server √ √ 读、写
Oracle √ √ 读、写
Sqlite3 √ √ 读、写
无结构流 CSV √ √ 读、写
XLSX（excel） √ √ 读、写

数据同步用户手册

使用go-etl数据同步用户手册开始数据同步

数据同步开发宝典

参考go-etl数据同步开发者文档来帮助开发

数据同步工具编译

linux

编译依赖
  1. golang 1.20以及以上版本
构建
make dependencies
make release
去掉db2依赖

在编译前需要export IGNORE_PACKAGES=db2

export IGNORE_PACKAGES=db2
make dependencies
make release

windows

编译依赖
  1. 需要mingw-w64 with gcc 7.2.0以上的环境进行编译
  2. golang 1.20以及以上
  3. 最小编译环境为win7
构建
release.bat
去掉db2依赖

在编译前需要set IGNORE_PACKAGES=db2

set IGNORE_PACKAGES=db2
release.bat

编译产物

    +---datax---|---plugin---+---reader--mysql---|--README_zh-CN.md
    |                        | .......
    |                        |
    |                        |---writer--mysql---|--README_zh-CN.md
    |                        | .......
    |
    +---bin----datax
    +---exampales---+---csvpostgres----config.json
    |               |---db2------------config.json
    |               | .......
    |
    +---README_USER_zh-CN.md
  • datax/plugin下是各插件的文档
  • bin下的是数据同步程序datax
  • exampales下是各场景的数据同步的配置文档
  • README_USER_zh-CN.md是中文用户使用手册

模块简介

datax

本包将提供类似于阿里巴巴DataX的接口去实现go语言的离线数据同步框架框架，

readerPlugin(reader)—> Framework(Exchanger+Transformer) ->writerPlugin(riter)

采用Framework + plugin架构构建。将数据源读取和写入抽象成为Reader/Writer插件，纳入到整个同步框架中。

  • Reader：Reader为数据采集模块，负责采集数据源的数据，将数据发送给Framework。
  • Writer：Writer为数据写入模块，负责不断向Framework取数据，并将数据写入到目的端。
  • Framework：Framework用于连接reader和writer，作为两者的数据传输通道，并处理缓冲，流控，并发，数据转换等核心技术问题

具体可以参考go-etl数据同步开发者文档。

element

目前已经实现了go-etl中的数据类型以及数据类型转换，可以参考go-etl数据类型说明。

storage

database

目前已经实现了数据库的基础集成，抽象了数据库方言(Dialect)接口，具体实现可以参考数据库存储开发者指南。

stream

主要用于字节流的解析，如文件，消息队列，elasticsearch等，字节流格式可以是cvs，json, xml等。

file

主要用于文件的解析，如cvs，excel等，抽象了输入流（InputStream）和输出流（OutputStream）接口，具体实现可以参考类二维表文件存储开发者指南。

tools

工具集用于编译，新增许可证等

datax

build
go generate ./...

发布命令，用于将由开发者开发的reader和writer插件注册到程序中的代码

另外，该命令也会把编译信息如软件版本，git版本，go编译版本和编译时间写入命令行中

plugin

数据源插件模板新增工具，用于新增一个reader或writer模板，配合发布命令使用，减少开发者负担

release

数据同步程序和用户使用文档打包工具

license

用于自动新增go代码文件中许可证并使用gofmt -s -w格式化代码

go run tools/license/main.go