Update data_stream_print.myc
This commit is contained in:
@@ -1,7 +1,7 @@
|
|||||||
;; Skip: data output to stdout
|
;; Skip: data output to stdout
|
||||||
(do
|
(do
|
||||||
(def EURUSD (create-m1-stream "EURUSD" (date "2020-01-03 09:30:00") (date "2020-01-03 17:30:00")))
|
(def EURUSD (create-m1-stream "EURUSD" (date "2020-01-03 09:30:00") (date "2020-01-03 13:30:00")))
|
||||||
(def GER40 (create-m1-stream "GER40" (date "2020-01-03 09:30:00") (date "2020-01-03 17:30:00")))
|
(def GER40 (create-m1-stream "GER40" (date "2020-01-03 09:30:00") (date "2020-01-03 13:30:00")))
|
||||||
|
|
||||||
;; Sink: print returns void, so nothing is propagated downstream
|
;; Sink: print returns void, so nothing is propagated downstream
|
||||||
|
|
||||||
@@ -19,19 +19,4 @@
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
; TODO: IDEE - pipe mit automatischer Value-Akkumulation: pipe <lookback> <inputs>
|
|
||||||
|
|
||||||
(pipe 2 [EURUSD GER40]
|
|
||||||
(fn [eu ge]
|
|
||||||
(do
|
|
||||||
; eu und ge werden hier zu Serien mit lookback 2
|
|
||||||
(def dax (.close (ge 0)))
|
|
||||||
(push gs dax)
|
|
||||||
(def eur (- dax (ge 1)))
|
|
||||||
(print cnt ": dax=" eur " (" (/ eur (.close (eu 0))) "$)" )
|
|
||||||
(assign cnt (+ cnt 1))
|
|
||||||
)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user