Technologieaustausch

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Laden Sie dataX herunter

https://datax-opensource.oss-cn-hangzhou.aliyuncs.com/202308/datax.tar.gz

Dann

Entpacken Sie es nach dem Herunterladen in ein lokales Verzeichnis, geben Sie das bin-Verzeichnis ein und führen Sie den Synchronisierungsauftrag aus:

$ cd  {YOUR_DATAX_HOME}/bin
$ python datax.py {YOUR_JOB.json}

Es ist erforderlich, dass Sie über Python, JDK1.8 und Maven3 verfügen

Der erste Schritt besteht darin, die Jobkonfigurationsdatei (JSON-Format) zu erstellen.

Vorlagentyp:

#stream2stream.json
{
"Arbeit": {
"Inhalt": [
      {
"Leser": {
"Name": "Streamreader",
"Parameter": {
"sliceRecordCount": 10,
"Spalte": [
              {
"Typ": "lang",
"Wert": "10"
              },
              {
"Typ": "Zeichenfolge",
„value“: „Hallo, hallo, world-DataX“
              }
            ]
          }
        },
"Schriftsteller": {
"Name": "Streamwriter",
"Parameter": {
"Kodierung": "UTF-8",
"drucken": wahr
          }
        }
      }
    ],
"Einstellung": {
"Geschwindigkeit": {
"Kanal": 5
       }
    }
  }
}

Start-up

$ cd {IHR_DATAX_DIR_BIN}
$ python datax.py ./stream2stream.json

Welchen Reader oder Writer möchten Sie auf der linken Seite von Github verwenden?

Gehen Sie einfach zur aktuellen Ressource und verwenden Sie den von ihm bereitgestellten JSON.

Es spielt keine Rolle, ob Sie Github nicht öffnen können. In den Plugins im heruntergeladenen Ordner befinden sich Vorlagen.

sehr einfach.

Beispiel

Beispiele zum Lesen und Schreiben von MySQL

 
{"job": {"content": [{"reader": {"name": "mysqlreader", "parameter": {"username": "root","password": "123123","column": ["*"],"splitPk": "ID","where": "ID <= 1888","connection": [{"jdbcUrl": ["jdbc:mysql://192.168.1.1:3306/xxx?useUnicode=true&characterEncoding=utf8"], "table": ["t_member"]}]}}, "writer": {"name": "mysqlwriter", "parameter": {"column": ["*"], "connection": [{"jdbcUrl": "jdbc:mysql://192.168.1.2:3306/xxx?useUnicode=true&characterEncoding=utf8","table": ["t_xxx"]}], "password": "123123","preSql": ["执行写入前执行的语句，比如删除表啊，之类的"], "session": ["set session sql_mode='ANSI'"], "username": "root", "writeMode": "insert"}}}], "setting": {"speed": {"channel": "5"}}}
}