من با اضافه کردن 15 مورد آخر، منهای آخرین مورد، از تاریخچه binance، یک DataFrame پانداهای جدید ساختم. و هر دقیقه داده های جدید را به DataFrame تازه ساخته شده اضافه می کنم. این عالی کار می کند و پس از چند دقیقه خروجی زیر را می دهد:
باز بسته . زمان بالا 0 61095. 98000000 61099. 44000000 . 61115. 93000000 2021-11-05 15:34:00 1 61099. 45000000 61038. 01000000 . 61104. 11000000 2021-11-05 15:35:00 2 61038. 00000000 61010. 96000000 . 61080. 0500000 2021-11-05 15:36:00 3 61010. 97000000 60978. 94000000 . 61017. 93000000 2021-11-05 15:37:00 4 60977. 80000000 60945. 65000000 . 60990. 54000000 2021-11-05 15:38:00 5 60945. 65000000 60900. 00000000 . 60958. 00000000 2021-11-05 15:39:00 6 60900. 00000000 60991. 44000000 . 60993. 71000000 2021-11-05 15:40:00 7 60991. 45000000 60888. 04000000 . 60996. 14000000 2021-11-05 15:41:00 8 60888. 04000000 60880. 94000000 . 60906. 9800000 2021-11-05 15:42:00 9 60880. 95000000 60810. 99000000 . 60880. 9500000 2021-11-05 15:43:00 10 60810. 99000000 60763. 94000000 . 60864. 74000000 2021-11-05 15:44:00 11 60763. 95000000 60872. 14000000 . 60896. 86000000 2021-11-05 15:45:00 12 60873. 17000000 60908. 84000000 . 60934. 22000000 2021-11-05 15:46:00 13 60908. 84000000 60844. 19000000 . 60914. 94000000 2021-11-05 15:47:00 14 60844. 18000000 60870. 40000000 . 60879. 34000000 2021-11-05 15:48:00 15 60870. 39000000 60845. 01000000 . 60877. 53000000 2021-11-05 15:49:00 16 60845. 02000000 60900. 62000000 . 60920. 64000000 2021-11-05 15:50:00 17 60900. 63000000 60873. 40000000 . 60901. 29000000 2021-11-05 15:51:00 [18 ردیف x 5 ستون]
حالا می خواهم اسیلاتور تصادفی را به این DataFrame اضافه کنم. من این را با اضافه کردن خط زیر به کد خود امتحان کردم:
df. ta. stoch(high='high', low='low', k=14, d=3, append=True)
با این حال، پس از افزودن این کد، DataFrame من دیگر با دستور چاپ نشان داده نمی شود و زمانی که می خواهم آن را چاپ کنم، استوکاستیک نیز نشان داده نمی شود. چگونه می توانم استوکاستیک را با DataFrame خودم کار کنم؟اگر سوالی دارید، بپرسید! پیشاپیش متشکرمکد کامل من در زیر:
2021 '، حد = 1000) سوکت = "wss: //stream. binance. com: 9443/ws/btcusdt@kline_1m" hist_df = pd. dataframe (تاریخی) hist_df. columns = ["زمان باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز" ، "باز"."بالا" ، "کم" ، "بستن" ، "جلد" ، "زمان نزدیک" ، "نقل قول حجم دارایی" ، "تعداد معاملات" ، "حجم پایه سل" ، "حجم نقل قول سل" ، "نادیده گرفتن"] defon_open (ws): چاپ ("اتصال باز شده") def on_close (ws): چاپ ("اتصال بسته") dic = history_open_price = hist_df ['باز'] [-15: -1] history_close_price = hist_df ['close'][-15: -1] HISTORY_HIGHEST_PRICE = HIST_DF ['HIGH'] [-15: -1] HISTORY_LOWEST_PRICE = HIST_DF ['LOW'] [-15: -1] HISTORY_TIME = PD. TO_DATETIME (HIST_DF ['OPEN TIME']/1000 ، واحد = 's') [-15: -1] برای A ، B در HISTORY_OPEN_PRICE. ITEMS (): DIC ['Open']. ضمیمه (B) برای A ، B در HISTORY_CLOSE_PRICE. ITEMS (): DIC['Close']. ضمیمه (b) برای A ، B در HISTORY_HIGHEST_PRICE. ITEMS (): DIC ['HIGH']. ضمیمه (B) برای A ، B در HISTORY_LOWEST_PRICE. ITEMS (): DIC ['LOW']. ضمیمه (ب) برای a ، b در history_time. items (): dic ['time']. ضمیمه (str (b)) def on_message (ws ، پیام): json_message = json. loads (پیام) شمع = json_message ['k '] Open_price = شمع [' o '] close_price = شمع [' c '] بالاترین_پریس = شمع [' h '] پایین _price = شمع [' l '] وضعیت = شمع [' x '] open_time = pd. to_datetime (شمع['t']/1000 ، واحد = 's') اگر وضعیت: dic ['Open']. ضمیمه (Open_price) dic ['Close']. ضمیمه (close_price) dic ['high']. ضمیمه (بالاترین_پریس)dic ['low']. ضمیمه (کمترین_پریس) dic ['time']. ضمیمه (str (Open_time)) df = pd. dataframe (dic) # df. ta. stoch (بالا = 'بالا' ، کم = 'کم'، k = 14 ، d = 3 ، append = true) print (df) ws = websocket. websocketapp (سوکت ، on_open = on_open ، on_close = on_close ، on_message = on_message) ws. run_forever ()
معاملات FX...
ما را در سایت معاملات FX دنبال می کنید
برچسب :
نویسنده : شهلا ریاحی
بازدید : <-PostHit->
تاريخ : چهارشنبه
15 شهريور
1402 ساعت: 21:43