Κοινή χρήση τεχνολογίας

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

Λήψη δεδομένωνX

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

Επειτα

Μετά τη λήψη, αποσυμπιέστε τον σε έναν τοπικό κατάλογο, εισαγάγετε τον κατάλογο bin και εκτελέστε την εργασία συγχρονισμού:

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

Απαιτείται να έχετε python, jdk1.8 και maven3

Το πρώτο βήμα είναι να δημιουργήσετε το αρχείο διαμόρφωσης εργασίας (μορφή json)

Τύπος προτύπου:

#stream2stream.json
{
"δουλειά": {
"περιεχόμενο": [
      {
"αναγνώστης": {
"name": "streamreader",
"παράμετρος": {
"sliceRecordCount": 10,
"στήλη": [
              {
"type": "μακρύ",
"value": "10"
              },
              {
"type": "string",
"value": "γεια, γεια, world-DataX"
              }
            ]
          }
        },
"συγγραφέας": {
"name": "streamwriter",
"παράμετρος": {
"encoding": "UTF-8",
«εκτύπωση»: αλήθεια
          }
        }
      }
    ],
"ρύθμιση": {
"Ταχύτητα": {
"κανάλι": 5
       }
    }
  }
}

ξεκίνα

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

Στην αριστερή πλευρά του github, ποιον αναγνώστη ή ποιον συγγραφέα θέλετε να χρησιμοποιήσετε;

Απλώς μεταβείτε στο τρέχον resouece και χρησιμοποιήστε το json που έδωσε.

Δεν έχει σημασία αν δεν μπορείτε να ανοίξετε το github, υπάρχουν πρότυπα στα πρόσθετα στο φάκελο που κατεβάσατε.

πολύ απλό.

παράδειγμα

Παραδείγματα ανάγνωσης και γραφής 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"}}}
}