# datax-docker

**Repository Path**: arvin-up/datax-docker

## Basic Information

- **Project Name**: datax-docker
- **Description**: 基于docker运行的datax
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-07-30
- **Last Updated**: 2025-08-14

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Datax docker镜像使用文档


___

## 1 快速介绍

### 启动命令

```sh
docker run --rm -it --name datax-docker \
-e JAVA_OPTS="-Xms128m -Xmx128m" \
-e JOB_JSON="$(cat data.json)" \
-e JOB_WEB_HOOK="http://localhost:8080/auto-sphere/api/user/login" \
-e JOB_REPORT_INTERVAL="10000" \
-e JOB_ID="66" \
registry.cn-chengdu.aliyuncs.com/arvin-d-li/datax-docker:v1.0.0-master-20250731_222948
```

### 接口回调参数

```java
        Map<String, Object> param = new HashMap<>();
        param.put("jobId", jobId);
        // 读出记录总数
        param.put("readRecords", CommunicationTool.getTotalReadRecords(communication));
        // 读写失败总数
        param.put("failedRecords", CommunicationTool.getTotalErrorRecords(communication));
        param.put("state", communication.getState().toString());
        param.put("isFinished", communication.getState().isFinished());
        param.put("currentTimeMillis", System.currentTimeMillis());
```



### data.json示例

```json
{
  "job": {
    "content": [
      {
        "reader": {
          "name": "rdbmsreader",
          "parameter": {
            "connection": [
              {
                "querySql": [
                  "select * from algorithm"
                ],
                "jdbcUrl": [
                  "jdbc:mysql://10.1.33.114:3306/inference_center"
                ]
              }
            ],
            "username": "root",
            "password": "82325588"
          }
        },
        "writer": {
          "name": "streamwriter",
          "parameter": {
            "encoding": "UTF-8",
            "print": true
          }
        }
      }
    ],
    "setting": {
      "speed": {
        "channel": 1
      }
    }
  }
}

```



```json
{
  "job": {
    "content": [
      {
        "reader": {
          "name": "streamreader",
          "parameter": {
            "sliceRecordCount": 10,
            "column": [
              {
                "type": "long",
                "value": "10"
              },
              {
                "type": "string",
                "value": "hello，你好，世界-DataX"
              }
            ]
          }
        },
        "writer": {
          "name": "streamwriter",
          "parameter": {
            "encoding": "UTF-8",
            "print": true
          }
        }
      }
    ],
    "setting": {
      "speed": {
        "channel": 5
      }
    }
  }
}
```