Как реализовать этот вариант использования в RxPY v3 - PullRequest
0 голосов
/ 11 июля 2019

Мне очень трудно принять Reactive.Я считаю, что моя проблема в том, что примеры слишком упрощены, поэтому я не уверен, как структурировать реальное решение.Я надеюсь, что кто-то поможет мне преодолеть горб, помогая решить реальную проблему.Я хотел бы сделать это в RxPY v3.

Вариант использования таков.У вас есть бесконечный поток котировок акций для нескольких акций с символом, заявкой и запросом.У вас также есть количество позиции (сколько акций у вас есть), которое начинается с нуля.Котировки и количество на акцию - это бесконечные наблюдаемые значения.

У вас также есть три триггерные цены: цена входа, целевая цена и стоп-цена.Если ваша позиция равна нулю, тогда цена входа активна.Если цена акции повышается до цены входа, вы принимаете решение о покупке акции.Это приведет к тому, что ваша наблюдаемая позиция изменится на нечто большее, чем ноль.

Как только ваша позиция станет больше нуля, целевая цена и цена стопа станут активными.Если цена поднимется до целевой цены, вы предпримете действие по продаже акций с целью получения прибыли.Если цена упадет до стоп-цены, вы предпримете попытку продать акцию с убытком.В любом случае, ваша позиция снова станет нулевой, поэтому цена входа снова станет активной.

Является ли это хорошим вариантом использования RxPY?Если да, может ли кто-нибудь показать мне хотя бы псевдокод, если не реальный код, чтобы реализовать это?Я не уверен, как подойти к этому.Лучше всего это сделать в одном большом выражении или это как-то взаимодействие нескольких выражений?Всегда ли действие остается в бесконечной наблюдаемой цепочке, или эти вещи живут и умирают, живут и умирают при изменении состояния?

Любой вклад очень ценится.

1 Ответ

0 голосов
/ 18 июля 2019

С помощью нескольких очень хороших людей в канале #rxpy http://pythondev.slack.com (особый привет Еву, моему шерпу RxPY), я смог заставить это работать.https://github.com/gargleblaster/rxpy_laboratory

...