get_last_day_data.dag 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676
  1. {
  2. "user_name": "test",
  3. "user_id": "test",
  4. "project_name": "test",
  5. "project_id": "test",
  6. "itermidate_data": [
  7. "hdfs://host:port/uri"
  8. ],
  9. "nodes": [
  10. {
  11. "id": "77a6e831-bb62-42e1-be8d-97699db00e73",
  12. "name": "DataSource",
  13. "op": "datasource",
  14. "data": {
  15. "input_source": [
  16. {
  17. "dataSelect": true,
  18. "dataField": "id",
  19. "dataType": "int"
  20. },
  21. {
  22. "dataSelect": true,
  23. "dataField": "ssn",
  24. "dataType": "string"
  25. },
  26. {
  27. "dataSelect": true,
  28. "dataField": "test2",
  29. "dataType": "int"
  30. }
  31. ],
  32. "input_table": 5
  33. }
  34. },
  35. {
  36. "id": "ed5475dc-b611-47ce-b2ab-475e3ab27e03",
  37. "name": "last_day",
  38. "op": "datasource",
  39. "data": {
  40. "input_source": [
  41. {
  42. "dataSelect": true,
  43. "dataField": "id",
  44. "dataType": "int"
  45. },
  46. {
  47. "dataSelect": true,
  48. "dataField": "ssn",
  49. "dataType": "string"
  50. },
  51. {
  52. "dataSelect": true,
  53. "dataField": "test2",
  54. "dataType": "int"
  55. }
  56. ],
  57. "input_table": 5
  58. }
  59. },
  60. {
  61. "id": "371ce58d-4931-455c-921e-ea5007726aaf",
  62. "name": "last_week",
  63. "op": "datasource",
  64. "data": {
  65. "input_source": [
  66. {
  67. "dataSelect": true,
  68. "dataField": "id",
  69. "dataType": "int"
  70. },
  71. {
  72. "dataSelect": true,
  73. "dataField": "ssn",
  74. "dataType": "string"
  75. },
  76. {
  77. "dataSelect": true,
  78. "dataField": "test2",
  79. "dataType": "int"
  80. }
  81. ],
  82. "input_table": 5
  83. }
  84. },
  85. {
  86. "id": "fa7c114d-2fe2-4c5c-84e4-f13ad9549e2e",
  87. "name": "last_month",
  88. "op": "datasource",
  89. "data": {
  90. "input_source": [
  91. {
  92. "dataSelect": true,
  93. "dataField": "id",
  94. "dataType": "int"
  95. },
  96. {
  97. "dataSelect": true,
  98. "dataField": "ssn",
  99. "dataType": "string"
  100. },
  101. {
  102. "dataSelect": true,
  103. "dataField": "test2",
  104. "dataType": "int"
  105. }
  106. ],
  107. "input_table": 5
  108. }
  109. },
  110. {
  111. "id": "b20c3b19-6dd1-417a-ba36-387fed05b41c",
  112. "name": "last_year",
  113. "op": "datasource",
  114. "data": {
  115. "input_source": [
  116. {
  117. "dataSelect": true,
  118. "dataField": "id",
  119. "dataType": "int"
  120. },
  121. {
  122. "dataSelect": true,
  123. "dataField": "ssn",
  124. "dataType": "string"
  125. },
  126. {
  127. "dataSelect": true,
  128. "dataField": "test2",
  129. "dataType": "int"
  130. }
  131. ],
  132. "input_table": 5
  133. }
  134. },
  135. {
  136. "id": "110cc156-50d9-4475-bfd4-52b45664567a",
  137. "name": "next_day",
  138. "op": "datasource",
  139. "data": {
  140. "input_source": [
  141. {
  142. "dataSelect": true,
  143. "dataField": "id",
  144. "dataType": "int"
  145. },
  146. {
  147. "dataSelect": true,
  148. "dataField": "ssn",
  149. "dataType": "string"
  150. },
  151. {
  152. "dataSelect": true,
  153. "dataField": "test2",
  154. "dataType": "int"
  155. }
  156. ],
  157. "input_table": 5
  158. }
  159. },
  160. {
  161. "id": "35960a11-4666-4877-85a0-8f55737684bf",
  162. "name": "next_week",
  163. "op": "datasource",
  164. "data": {
  165. "input_source": [
  166. {
  167. "dataSelect": true,
  168. "dataField": "id",
  169. "dataType": "int"
  170. },
  171. {
  172. "dataSelect": true,
  173. "dataField": "ssn",
  174. "dataType": "string"
  175. },
  176. {
  177. "dataSelect": true,
  178. "dataField": "test2",
  179. "dataType": "int"
  180. }
  181. ],
  182. "input_table": 5
  183. }
  184. },
  185. {
  186. "id": "93984bef-575c-4e97-856c-2850c295a0b1",
  187. "name": "next_month",
  188. "op": "datasource",
  189. "data": {
  190. "input_source": [
  191. {
  192. "dataSelect": true,
  193. "dataField": "id",
  194. "dataType": "int"
  195. },
  196. {
  197. "dataSelect": true,
  198. "dataField": "ssn",
  199. "dataType": "string"
  200. },
  201. {
  202. "dataSelect": true,
  203. "dataField": "test2",
  204. "dataType": "int"
  205. }
  206. ],
  207. "input_table": 5
  208. }
  209. },
  210. {
  211. "id": "96d5fa5b-88d4-4905-9dd8-4f5eb171cd6b",
  212. "name": "next_year",
  213. "op": "datasource",
  214. "data": {
  215. "input_source": [
  216. {
  217. "dataSelect": true,
  218. "dataField": "id",
  219. "dataType": "int"
  220. },
  221. {
  222. "dataSelect": true,
  223. "dataField": "ssn",
  224. "dataType": "string"
  225. },
  226. {
  227. "dataSelect": true,
  228. "dataField": "test2",
  229. "dataType": "int"
  230. }
  231. ],
  232. "input_table": 5
  233. }
  234. },
  235. {
  236. "id": "ff47c3f8-2551-4fe5-b182-e94cbd31ddf8",
  237. "name": "next_oooo",
  238. "op": "datasource",
  239. "data": {
  240. "input_source": [
  241. {
  242. "dataSelect": true,
  243. "dataField": "id",
  244. "dataType": "int"
  245. },
  246. {
  247. "dataSelect": true,
  248. "dataField": "ssn",
  249. "dataType": "string"
  250. },
  251. {
  252. "dataSelect": true,
  253. "dataField": "test2",
  254. "dataType": "int"
  255. }
  256. ],
  257. "input_table": 5
  258. }
  259. },
  260. {
  261. "id": "143cfcb1-f566-4f97-b38b-9b62d40fe4cd",
  262. "name": "SQL",
  263. "op": "script",
  264. "data": {
  265. "input": 1,
  266. "output": [
  267. {
  268. "outputVar": "r3"
  269. }
  270. ],
  271. "script": "Select * from table11",
  272. "param": "test SQL Param"
  273. }
  274. },
  275. {
  276. "id": "6b437370-0468-44da-a0bb-e637e33f3efb",
  277. "name": "PySpark",
  278. "op": "script",
  279. "data": {
  280. "input": 1,
  281. "output": [
  282. {
  283. "outputVar": "r2"
  284. }
  285. ],
  286. "script": "import pySpark\n\nprint('hello wolrd pySpark')",
  287. "param": "test PySpark Param"
  288. }
  289. },
  290. {
  291. "id": "c79943c6-9513-4cf8-9c24-d5fa89b6cdde",
  292. "name": "Python",
  293. "op": "script",
  294. "data": {
  295. "input": 1,
  296. "output": [
  297. {
  298. "outputVar": "r1"
  299. }
  300. ],
  301. "script": "import test\nprint('hello world')",
  302. "param": "test param",
  303. "package": "test = 1.1\ntest1 = 2.2"
  304. }
  305. }
  306. ],
  307. "edges": [
  308. {
  309. "id": "b29bcdc7-b543-4d4a-9bd7-7fa74f3a548d",
  310. "source": "77a6e831-bb62-42e1-be8d-97699db00e73",
  311. "target": "143cfcb1-f566-4f97-b38b-9b62d40fe4cd"
  312. },
  313. {
  314. "id": "e87690d4-f71d-44f5-85fc-3c14b32b323e",
  315. "source": "77a6e831-bb62-42e1-be8d-97699db00e73",
  316. "target": "c79943c6-9513-4cf8-9c24-d5fa89b6cdde"
  317. },
  318. {
  319. "id": "4c312a41-5abf-47a8-a6ad-c2fbba147c4e",
  320. "source": "77a6e831-bb62-42e1-be8d-97699db00e73",
  321. "target": "6b437370-0468-44da-a0bb-e637e33f3efb"
  322. }
  323. ],
  324. "graph": {
  325. "cells": [
  326. {
  327. "shape": "dag-edge",
  328. "attrs": {
  329. "line": {
  330. "strokeDasharray": ""
  331. }
  332. },
  333. "id": "b29bcdc7-b543-4d4a-9bd7-7fa74f3a548d",
  334. "zIndex": -1,
  335. "source": {
  336. "cell": "77a6e831-bb62-42e1-be8d-97699db00e73",
  337. "port": "bottomPort"
  338. },
  339. "target": {
  340. "cell": "143cfcb1-f566-4f97-b38b-9b62d40fe4cd",
  341. "port": "topPort"
  342. }
  343. },
  344. {
  345. "shape": "dag-edge",
  346. "attrs": {
  347. "line": {
  348. "strokeDasharray": ""
  349. }
  350. },
  351. "id": "e87690d4-f71d-44f5-85fc-3c14b32b323e",
  352. "zIndex": -1,
  353. "source": {
  354. "cell": "77a6e831-bb62-42e1-be8d-97699db00e73",
  355. "port": "bottomPort"
  356. },
  357. "target": {
  358. "cell": "c79943c6-9513-4cf8-9c24-d5fa89b6cdde",
  359. "port": "topPort"
  360. }
  361. },
  362. {
  363. "shape": "dag-edge",
  364. "attrs": {
  365. "line": {
  366. "strokeDasharray": ""
  367. }
  368. },
  369. "id": "4c312a41-5abf-47a8-a6ad-c2fbba147c4e",
  370. "zIndex": -1,
  371. "source": {
  372. "cell": "77a6e831-bb62-42e1-be8d-97699db00e73",
  373. "port": "bottomPort"
  374. },
  375. "target": {
  376. "cell": "6b437370-0468-44da-a0bb-e637e33f3efb",
  377. "port": "topPort"
  378. }
  379. },
  380. {
  381. "position": {
  382. "x": 240,
  383. "y": 130
  384. },
  385. "size": {
  386. "width": 180,
  387. "height": 80
  388. },
  389. "view": "react-shape-view",
  390. "shape": "dag-node",
  391. "component": {
  392. "key": null,
  393. "ref": null,
  394. "props": {},
  395. "_owner": null,
  396. "_store": {}
  397. },
  398. "ports": {
  399. "groups": {
  400. "top": {
  401. "position": "top",
  402. "attrs": {
  403. "circle": {
  404. "r": 4,
  405. "magnet": true,
  406. "stroke": "#C2C8D5",
  407. "strokeWidth": 1,
  408. "fill": "#fff"
  409. }
  410. }
  411. },
  412. "bottom": {
  413. "position": "bottom",
  414. "attrs": {
  415. "circle": {
  416. "r": 4,
  417. "magnet": true,
  418. "stroke": "#C2C8D5",
  419. "strokeWidth": 1,
  420. "fill": "#fff"
  421. }
  422. }
  423. }
  424. },
  425. "items": [
  426. {
  427. "id": "bottomPort",
  428. "group": "bottom"
  429. }
  430. ]
  431. },
  432. "id": "77a6e831-bb62-42e1-be8d-97699db00e73",
  433. "data": {
  434. "label": "DataSource",
  435. "status": "default",
  436. "type": "datasource",
  437. "id": "77a6e831-bb62-42e1-be8d-97699db00e73",
  438. "inputSource": [
  439. {
  440. "dataSelect": false,
  441. "dataField": "name",
  442. "dataType": "string"
  443. },
  444. {
  445. "dataSelect": true,
  446. "dataField": "address",
  447. "dataType": "string"
  448. }
  449. ],
  450. "dataTable": 5
  451. },
  452. "zIndex": 1
  453. },
  454. {
  455. "position": {
  456. "x": 480,
  457. "y": 300
  458. },
  459. "size": {
  460. "width": 180,
  461. "height": 36
  462. },
  463. "view": "react-shape-view",
  464. "shape": "dag-node",
  465. "component": {
  466. "key": null,
  467. "ref": null,
  468. "props": {},
  469. "_owner": null,
  470. "_store": {}
  471. },
  472. "ports": {
  473. "groups": {
  474. "top": {
  475. "position": "top",
  476. "attrs": {
  477. "circle": {
  478. "r": 4,
  479. "magnet": true,
  480. "stroke": "#C2C8D5",
  481. "strokeWidth": 1,
  482. "fill": "#fff"
  483. }
  484. }
  485. },
  486. "bottom": {
  487. "position": "bottom",
  488. "attrs": {
  489. "circle": {
  490. "r": 4,
  491. "magnet": true,
  492. "stroke": "#C2C8D5",
  493. "strokeWidth": 1,
  494. "fill": "#fff"
  495. }
  496. }
  497. }
  498. },
  499. "items": [
  500. {
  501. "id": "topPort",
  502. "group": "top"
  503. },
  504. {
  505. "id": "bottomPort",
  506. "group": "bottom"
  507. }
  508. ]
  509. },
  510. "id": "143cfcb1-f566-4f97-b38b-9b62d40fe4cd",
  511. "data": {
  512. "label": "SQL",
  513. "status": "default",
  514. "type": "script",
  515. "id": "143cfcb1-f566-4f97-b38b-9b62d40fe4cd",
  516. "paramText": "test SQL Param",
  517. "scriptText": "Select * from table11",
  518. "outputData": [
  519. {
  520. "outputVar": "r3"
  521. }
  522. ],
  523. "inputNumber": 1
  524. },
  525. "zIndex": 2
  526. },
  527. {
  528. "position": {
  529. "x": 230,
  530. "y": 310
  531. },
  532. "size": {
  533. "width": 180,
  534. "height": 36
  535. },
  536. "view": "react-shape-view",
  537. "shape": "dag-node",
  538. "component": {
  539. "key": null,
  540. "ref": null,
  541. "props": {},
  542. "_owner": null,
  543. "_store": {}
  544. },
  545. "ports": {
  546. "groups": {
  547. "top": {
  548. "position": "top",
  549. "attrs": {
  550. "circle": {
  551. "r": 4,
  552. "magnet": true,
  553. "stroke": "#C2C8D5",
  554. "strokeWidth": 1,
  555. "fill": "#fff"
  556. }
  557. }
  558. },
  559. "bottom": {
  560. "position": "bottom",
  561. "attrs": {
  562. "circle": {
  563. "r": 4,
  564. "magnet": true,
  565. "stroke": "#C2C8D5",
  566. "strokeWidth": 1,
  567. "fill": "#fff"
  568. }
  569. }
  570. }
  571. },
  572. "items": [
  573. {
  574. "id": "topPort",
  575. "group": "top"
  576. },
  577. {
  578. "id": "bottomPort",
  579. "group": "bottom"
  580. }
  581. ]
  582. },
  583. "id": "6b437370-0468-44da-a0bb-e637e33f3efb",
  584. "data": {
  585. "label": "PySpark",
  586. "status": "default",
  587. "type": "script",
  588. "id": "6b437370-0468-44da-a0bb-e637e33f3efb",
  589. "paramText": "test PySpark Param",
  590. "scriptText": "import pySpark\n\nprint('hello wolrd pySpark')",
  591. "outputData": [
  592. {
  593. "outputVar": "r2"
  594. }
  595. ],
  596. "inputNumber": 1
  597. },
  598. "zIndex": 3
  599. },
  600. {
  601. "position": {
  602. "x": -10,
  603. "y": 310
  604. },
  605. "size": {
  606. "width": 180,
  607. "height": 36
  608. },
  609. "view": "react-shape-view",
  610. "shape": "dag-node",
  611. "component": {
  612. "key": null,
  613. "ref": null,
  614. "props": {},
  615. "_owner": null,
  616. "_store": {}
  617. },
  618. "ports": {
  619. "groups": {
  620. "top": {
  621. "position": "top",
  622. "attrs": {
  623. "circle": {
  624. "r": 4,
  625. "magnet": true,
  626. "stroke": "#C2C8D5",
  627. "strokeWidth": 1,
  628. "fill": "#fff"
  629. }
  630. }
  631. },
  632. "bottom": {
  633. "position": "bottom",
  634. "attrs": {
  635. "circle": {
  636. "r": 4,
  637. "magnet": true,
  638. "stroke": "#C2C8D5",
  639. "strokeWidth": 1,
  640. "fill": "#fff"
  641. }
  642. }
  643. }
  644. },
  645. "items": [
  646. {
  647. "id": "topPort",
  648. "group": "top"
  649. },
  650. {
  651. "id": "bottomPort",
  652. "group": "bottom"
  653. }
  654. ]
  655. },
  656. "id": "c79943c6-9513-4cf8-9c24-d5fa89b6cdde",
  657. "data": {
  658. "label": "Python",
  659. "status": "default",
  660. "type": "script",
  661. "id": "c79943c6-9513-4cf8-9c24-d5fa89b6cdde",
  662. "paramText": "test param",
  663. "scriptText": "import test\nprint('hello world')",
  664. "outputData": [
  665. {
  666. "outputVar": "r1"
  667. }
  668. ],
  669. "inputNumber": 1,
  670. "packageData": "test = 1.1\ntest1 = 2.2"
  671. },
  672. "zIndex": 4
  673. }
  674. ]
  675. }
  676. }