ADataXtasktype’sexampleanddiveintoinformationofPyDolphinScheduler.
TaskCustomDataxobject,declarebehaviorforcustomDataXtasktodolphinscheduler.
YouproviderjsontemplateforDataX,itcansynchronizedataaccordingtothetemplateyouprovided.
TaskDataXobject,declarebehaviorforDataXtasktodolphinscheduler.
Itshouldrundatabasedataxjobinmultiplysqllinkengine,suchas:-MySQL-Oracle-Postgresql-SQLServerYouproviderdatasource_nameanddatatarget_namecontainconnectioninformation,itdecisionswhichdatabasetypeanddatabaseinstancewouldsynchronousdata.
OverrideTask.task_paramsfordataxtask.
dataxtaskhavesomespecialsattributefortask_params,andisoddifwedirectlysetaspythonproperty,soweOverrideTask.task_paramshere.
#Definetheworkflowworkflow:name:"DataX"#Definethetasksundertheworkflowtasks:-name:tasktask_type:DataXdatasource_name:dbdatatarget_name:dbsql:showtables;target_table:table_test-name:task_custon_configtask_type:CustomDataXjson:$FILE{"example_datax.json"}