问：mongodb时间戳... ID=OqGjRX8BoQvtMeh7D0N- INDEX=0

设置任务依赖实现参数传递：设置节点依赖关系，调度配置都设置10分钟调度 1、使用两个赋值节点定义时间戳格式的时间开始时间： 参数：day=$[yyyy-mm-dd] start_time=$[hh24:mi:ss- 1/24/60*10] 赋值语言选ODPS SQL：select UNIX_TIMESTAMP("unknown unknown"); 结束时间： 参数：day=$[yyyy-mm-dd] end_time=$[hh24:mi:ss] 赋值语言选ODPS SQL：select UNIX_TIMESTAMP("unknown unknown"); 2、配置MongoDB同步节点添加本节点输入参数 start_time和end_time，取值自上游的两个赋值节点 MongoDB原始数据：脚本模式配置示例代码，源端create_time是double类型，存的时间戳。 "query": "{'create_time':{'$gte':unknown,'$lt':unknown}}", 脚本配置示例 { "type": "job", "steps": [ { "stepType": "mongodb", "parameter": { "datasource": "ds1", "query": "{'create_time':{'$gte':unknown,'$lt':unknown}}", "column": [ { "name": "doc_id", "type": "STRING" }, { "name": "create_time", "type": "DOUBLE" }, { "name": "date_time", "type": "DATE" } ], "collectionName": "test1" }, "name": "Reader", "category": "reader" }, { "stepType": "odps", "parameter": { "partition": "", "truncate": false, "compress": false, "datasource": "odps_first", "column": [ "doc_id", "create_time", "date_time" ], "emptyAsNull": false, "table": "tablename" }, "name": "Writer", "category": "writer" } ], "version": "2.0", "order": { "hops": [ { "from": "Reader", "to": "Writer" } ] }, "setting": { "errorLimit": { "record": "" }, "speed": { "throttle": false, "concurrent": 2 } }}，此回答整理自钉群“DataWorks交流群(答疑@机器人)”