datax_constants.py 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. # -*- coding:utf-8 -*-
  2. # 全量同步标记
  3. ALL_DATA_DATE = '19700101'
  4. # column_type
  5. COLUMN_TYPE_DATE = 'date'
  6. COLUMN_TYPE_DOUBLE = 'double'
  7. COLUMN_TYPE_INT = 'int'
  8. COLUMN_TYPE_LONG = 'long'
  9. COLUMN_TYPE_STRING = 'string'
  10. DS_MYSQL_JDBC_URL = 'jdbcUrl'
  11. DS_POSTGRE_SQL_JDBC_URL = 'jdbcUrl'
  12. DS_CLICK_HOUSE_JDBC_URL = 'jdbcUrl'
  13. # DataX作业配置生成器配置
  14. GEN_CONFIG_KEY_DATA_SOURCE = 'dataSource'
  15. GEN_CONFIG_KEY_COLUMN_TYPE = 'columnType'
  16. GEN_CONFIG_KEY_COLUMN_FORMAT = 'columnFormat'
  17. GEN_CONFIG_KEY_COLUMN_SPLITTER_ITEM_TYPE = 'splitterItemType'
  18. # for job.setting.speed
  19. JOB_SETTING_SPEED_BYTE = 'byte'
  20. JOB_SETTING_SPEED_CHANNEL = 'channel'
  21. JOB_SETTING_SPEED_RECORD = 'record'
  22. # for job.content[n].{reader/writer}.name
  23. PLUGIN_NAME = 'name'
  24. # for job.content[n].{reader/writer}.parameter
  25. PLUGIN_PARAMETER = 'parameter'
  26. # for job.content[n].{reader/writer}.column
  27. PLUGIN_PARAMETER_COLUMN = 'column'
  28. # for job.content[n].{reader}.addColumn
  29. PLUGIN_PARAMETER_ADD_COLUMN = 'addColumn'
  30. # for job.content[n].{reader/writer}.column[n].{index/type/name/format/splitter/itemtype}
  31. PLUGIN_PARAMETER_COLUMN_N_FORMAT = 'format'
  32. PLUGIN_PARAMETER_COLUMN_N_INDEX = 'index'
  33. PLUGIN_PARAMETER_COLUMN_N_ITEM_TYPE = "itemtype"
  34. PLUGIN_PARAMETER_COLUMN_N_NAME = 'name'
  35. PLUGIN_PARAMETER_COLUMN_N_SPLITTER = "splitter"
  36. PLUGIN_PARAMETER_COLUMN_N_TYPE = 'type'
  37. # for job.content[n].{reader/writer}.connection
  38. PLUGIN_PARAMETER_CONNECTION = 'connection'
  39. # for value of job.content[n].reader
  40. JOB_CONTENT_N_READER = 'reader'
  41. # for value of job.content[n].writer
  42. JOB_CONTENT_N_WRITER = 'writer'