{"id":41775,"date":"2026-05-15T09:05:10","date_gmt":"2026-05-15T06:05:10","guid":{"rendered":"https:\/\/fatihsoysal.com\/blog\/dinamik-forex-cifti-aboneligi-ile-websocket-veri-akisinizi-optimize-edin-asiri-yuklenmeyi-durdurun\/"},"modified":"2026-05-15T11:17:18","modified_gmt":"2026-05-15T08:17:18","slug":"dinamik-forex-cifti-aboneligi-ile-websocket-veri-akisinizi-optimize-edin-asiri-yuklenmeyi-durdurun","status":"publish","type":"post","link":"https:\/\/fatihsoysal.com\/blog\/dinamik-forex-cifti-aboneligi-ile-websocket-veri-akisinizi-optimize-edin-asiri-yuklenmeyi-durdurun\/","title":{"rendered":"Dinamik Forex \u00c7ifti Aboneli\u011fi ile WebSocket Veri Ak\u0131\u015f\u0131n\u0131z\u0131 Optimize Edin: A\u015f\u0131r\u0131 Y\u00fcklenmeyi Durdurun"},"content":{"rendered":"

Dinamik Forex \u00c7ifti Aboneli\u011fi ile WebSocket Veri Ak\u0131\u015f\u0131n\u0131z\u0131 Optimize Edin: A\u015f\u0131r\u0131 Y\u00fcklenmeyi Durdurun<\/h2>\n

Forex piyasas\u0131nda anl\u0131k kararlar alman\u0131n \u00f6nemi tart\u0131\u015f\u0131lmaz. Bu kararlar\u0131n temelini olu\u015fturan g\u00fcvenilir ve h\u0131zl\u0131 veri ak\u0131\u015f\u0131, \u00e7o\u011fu zaman g\u00f6z ard\u0131 edilen ancak kritik bir unsurdur. \u00d6zellikle Python ile WebSocket \u00fczerinden finansal verilere eri\u015firken, gereksiz veri ak\u0131\u015f\u0131n\u0131n sisteminizi yava\u015flatabilece\u011fi, maliyetleri art\u0131rabilece\u011fi ve hatta API k\u0131s\u0131tlamalar\u0131na tak\u0131lman\u0131za neden olabilece\u011fi bir ger\u00e7ektir. Bu makalede, yaln\u0131zca ihtiyac\u0131n\u0131z olan Forex \u00e7iftlerine dinamik olarak abone olarak veri ak\u0131\u015f\u0131n\u0131z\u0131 nas\u0131l ak\u0131ll\u0131ca y\u00f6netece\u011finizi ve bu sayede performans\u0131n\u0131z\u0131 nas\u0131l maksimize edece\u011finizi ad\u0131m ad\u0131m inceleyece\u011fiz.<\/p>\n

Neden WebSocket Veri Ak\u0131\u015f\u0131n\u0131z\u0131 Y\u00f6netmelisiniz? A\u015f\u0131r\u0131 Y\u00fcklenmenin Gizli Maliyetleri Nelerdir?<\/h2>\n

Forex piyasas\u0131, d\u00fcnyan\u0131n en b\u00fcy\u00fck ve en likit finansal piyasas\u0131d\u0131r. G\u00fcnl\u00fck trilyonlarca dolarl\u0131k i\u015flem hacmiyle, yat\u0131r\u0131mc\u0131lar ve algoritmik sistemler i\u00e7in s\u00fcrekli bir veri ak\u0131\u015f\u0131 gerektirir. Bu veriler genellikle WebSocket protokol\u00fc \u00fczerinden ger\u00e7ek zamanl\u0131 olarak sa\u011flan\u0131r. Ancak, bir\u00e7ok geli\u015ftirici, ba\u015flang\u0131\u00e7ta t\u00fcm mevcut Forex \u00e7iftlerine (\u00f6rne\u011fin, EUR\/USD, GBP\/JPY, AUD\/CAD vb.) abone olma e\u011filimindedir. Bu yakla\u015f\u0131m, ilk bak\u0131\u015fta pratik gibi g\u00f6r\u00fcnse de, zamanla ciddi sorunlara yol a\u00e7abilir. A\u015f\u0131r\u0131 y\u00fcklenmi\u015f bir veri ak\u0131\u015f\u0131n\u0131n gizli maliyetleri ve olumsuz etkileri \u015funlard\u0131r:<\/p>\n

* Kaynak T\u00fcketimi ve Performans D\u00fc\u015f\u00fc\u015f\u00fc:<\/strong> T\u00fcm veri \u00e7iftlerine abone olmak, sunucudan istemciye s\u00fcrekli olarak b\u00fcy\u00fck miktarda veri ak\u0131\u015f\u0131 anlam\u0131na gelir. Bu durum, yerel sisteminizde (bilgisayar veya sunucu) CPU, bellek ve a\u011f bant geni\u015fli\u011fi gibi kaynaklar\u0131n gereksiz yere t\u00fcketilmesine neden olur. Verilerin i\u015flenmesi, filtrelenmesi ve depolanmas\u0131 i\u00e7in harcanan ekstra \u00e7aba, uygulaman\u0131z\u0131n genel performans\u0131n\u0131 d\u00fc\u015f\u00fcr\u00fcr, gecikmeleri (latency) art\u0131r\u0131r ve ticaret kararlar\u0131n\u0131z\u0131n zaman\u0131nda al\u0131nmas\u0131n\u0131 engelleyebilir. \u00d6zellikle h\u0131zl\u0131 ticaret stratejilerinde, milisaniyelerin bile \u00f6nemi b\u00fcy\u00fckt\u00fcr.
\n* API K\u0131s\u0131tlamalar\u0131 ve Maliyetler:<\/strong> \u00c7o\u011fu finansal veri sa\u011flay\u0131c\u0131s\u0131, API kullan\u0131mlar\u0131 i\u00e7in belirli k\u0131s\u0131tlamalar ve limitler uygular. Bu limitler genellikle saniye ba\u015f\u0131na istek say\u0131s\u0131, ayn\u0131 anda a\u00e7\u0131k tutulabilecek WebSocket ba\u011flant\u0131s\u0131 say\u0131s\u0131 veya toplam veri hacmi \u00fczerinden belirlenir. Gereksiz yere t\u00fcm verilere abone olmak, bu limitlere h\u0131zla ula\u015fman\u0131za neden olabilir. Limitlere tak\u0131lmak, hizmet kesintilerine yol a\u00e7abilir veya daha y\u00fcksek katmanl\u0131, dolay\u0131s\u0131yla daha pahal\u0131 abonelik planlar\u0131na ge\u00e7mek zorunda kalman\u0131za neden olabilir. K\u00fc\u00e7\u00fck \u00f6l\u00e7ekli bir yat\u0131r\u0131mc\u0131 veya geli\u015ftirici i\u00e7in bu ek maliyetler \u00f6nemli bir y\u00fck olu\u015fturabilir.
\n* Veri Kirlili\u011fi ve \u0130\u015fleme Karma\u015f\u0131kl\u0131\u011f\u0131:<\/strong> \u0130htiyac\u0131n\u0131z olmayan verileri almak, veri ak\u0131\u015f\u0131n\u0131z\u0131 “kirletir”. Bu kirlilik, \u00f6nemli bilgileri gereksiz g\u00fcr\u00fclt\u00fc aras\u0131nda bulmay\u0131 zorla\u015ft\u0131r\u0131r. Uygulaman\u0131z\u0131n, ilgilendi\u011finiz verileri ay\u0131klamak i\u00e7in daha karma\u015f\u0131k filtreleme ve i\u015fleme mant\u0131\u011f\u0131na sahip olmas\u0131 gerekir. Bu da kodun karma\u015f\u0131kl\u0131\u011f\u0131n\u0131 art\u0131r\u0131r, hata yapma olas\u0131l\u0131\u011f\u0131n\u0131 y\u00fckseltir ve bak\u0131m\u0131n\u0131 zorla\u015ft\u0131r\u0131r. Ayr\u0131ca, bu gereksiz verilerin depolanmas\u0131 da disk alan\u0131 maliyetlerini art\u0131r\u0131r ve veri taban\u0131n\u0131z\u0131n performans\u0131n\u0131 olumsuz etkileyebilir.
\n* Gecikme (Latency) ve Zamanlama Sorunlar\u0131:<\/strong> A\u011f \u00fczerinden aktar\u0131lan veri miktar\u0131 artt\u0131k\u00e7a, verilerin hedefe ula\u015fma s\u00fcresi de artar. Bu durum, \u00f6zellikle y\u00fcksek frekansl\u0131 ticaret (HFT) stratejileri i\u00e7in kritik olan gecikmeleri beraberinde getirir. Piyasa fiyatlar\u0131 s\u00fcrekli de\u011fi\u015firken, gecikmeli veri almak, yanl\u0131\u015f kararlar alman\u0131za veya arbitraj f\u0131rsatlar\u0131n\u0131 ka\u00e7\u0131rman\u0131za neden olabilir. Dinamik abonelik y\u00f6netimi, veri ak\u0131\u015f\u0131n\u0131 optimize ederek bu gecikmeleri minimize etmeye yard\u0131mc\u0131 olur.<\/p>\n

\u00d6zetle, veri ak\u0131\u015f\u0131n\u0131z\u0131 ak\u0131ll\u0131ca y\u00f6netmek, sadece sistem kaynaklar\u0131n\u0131 korumakla kalmaz, ayn\u0131 zamanda uygulaman\u0131z\u0131n istikrar\u0131n\u0131, performans\u0131n\u0131 ve maliyet etkinli\u011fini do\u011frudan etkiler. Dinamik Forex \u00e7ifti aboneli\u011fi, bu sorunlar\u0131n \u00fcstesinden gelmek i\u00e7in g\u00fc\u00e7l\u00fc ve esnek bir \u00e7\u00f6z\u00fcm sunar.<\/p>\n

WebSocket ve Forex Verileri: Temel Kavramlara H\u0131zl\u0131 Bir Bak\u0131\u015f<\/h2>\n

Veri ak\u0131\u015f\u0131 optimizasyonuna dalmadan \u00f6nce, temel kavramlar\u0131 anlamak \u00f6nemlidir. WebSocket protokol\u00fc ve Forex verilerinin yap\u0131s\u0131, bu optimizasyonun neden gerekli oldu\u011funu ve nas\u0131l \u00e7al\u0131\u015ft\u0131\u011f\u0131n\u0131 anlamam\u0131z i\u00e7in temel olu\u015fturur.<\/p>\n

* WebSocket Nedir?<\/strong>
\n Geleneksel HTTP protokol\u00fc, istemci-sunucu ileti\u015fimi i\u00e7in “istek-cevap” (request-response) modelini kullan\u0131r. Yani, istemci bir istek g\u00f6nderir, sunucu bir cevap d\u00f6nd\u00fcr\u00fcr ve ba\u011flant\u0131 genellikle kapan\u0131r. Ger\u00e7ek zamanl\u0131 uygulamalar (canl\u0131 sohbet, oyunlar, finansal veri ak\u0131\u015flar\u0131) i\u00e7in bu model verimsizdir \u00e7\u00fcnk\u00fc istemcinin s\u00fcrekli olarak yeni veri i\u00e7in sunucuyu yoklamas\u0131 (polling) gerekir. Bu da y\u00fcksek gecikmeye ve gereksiz a\u011f trafi\u011fine yol a\u00e7ar.
\n WebSocket, bu sorunu \u00e7\u00f6zmek i\u00e7in tasarlanm\u0131\u015f bir ileti\u015fim protokol\u00fcd\u00fcr. HTTP \u00fczerinden bir “el s\u0131k\u0131\u015fma” (handshake) ile ba\u015flayan WebSocket ba\u011flant\u0131s\u0131, bir kez kurulduktan sonra kal\u0131c\u0131, \u00e7ift y\u00f6nl\u00fc bir kanal olu\u015fturur. Bu, hem istemcinin hem de sunucunun birbirine istedi\u011fi zaman veri g\u00f6nderebilece\u011fi anlam\u0131na gelir. Sunucu, yeni bir veri oldu\u011funda (\u00f6rne\u011fin, yeni bir Forex fiyat\u0131) bunu an\u0131nda istemciye “push” edebilir, istemcinin s\u00fcrekli istek g\u00f6ndermesine gerek kalmaz. Bu sayede gecikmeler azal\u0131r ve a\u011f kaynaklar\u0131 daha verimli kullan\u0131l\u0131r. Python’da websockets<\/code> k\u00fct\u00fcphanesi, bu t\u00fcr ba\u011flant\u0131lar\u0131 kurmak ve y\u00f6netmek i\u00e7in olduk\u00e7a pop\u00fcler ve g\u00fc\u00e7l\u00fc bir ara\u00e7t\u0131r.<\/p>\n

* Forex Verileri ve Yap\u0131s\u0131:<\/strong>
\n Forex piyasas\u0131nda i\u015flem g\u00f6ren en temel veri, d\u00f6viz \u00e7iftlerinin (currency pairs) fiyatlar\u0131d\u0131r. Bir d\u00f6viz \u00e7ifti, bir para biriminin di\u011ferine g\u00f6re de\u011ferini ifade eder (\u00f6rne\u011fin, EUR\/USD, Euro’nun ABD Dolar\u0131 kar\u015f\u0131s\u0131ndaki de\u011feri). Bu fiyatlar genellikle iki bile\u015fenden olu\u015fur:
\n * Bid Fiyat\u0131 (Al\u0131\u015f Fiyat\u0131):<\/strong> Bir arac\u0131 kurumun (broker) belirli bir d\u00f6viz \u00e7iftini sizden almaya raz\u0131 oldu\u011fu fiyatt\u0131r. Yani, bu fiyattan sat\u0131\u015f yapabilirsiniz.
\n * Ask Fiyat\u0131 (Sat\u0131\u015f Fiyat\u0131):<\/strong> Bir arac\u0131 kurumun belirli bir d\u00f6viz \u00e7iftini size satmaya raz\u0131 oldu\u011fu fiyatt\u0131r. Yani, bu fiyattan al\u0131m yapabilirsiniz.
\n * Spread (Fark):<\/strong> Bid ve Ask fiyatlar\u0131 aras\u0131ndaki farkt\u0131r. Bu, arac\u0131 kurumun i\u015flem maliyetini ve kar marj\u0131n\u0131 temsil eder.
\n * Tick (Anl\u0131k Fiyat De\u011fi\u015fimi):<\/strong> Piyasadaki en k\u00fc\u00e7\u00fck fiyat hareketini ifade eder. WebSocket \u00fczerinden gelen veriler genellikle “tick” verileri \u015feklinde olur; yani, bir d\u00f6viz \u00e7iftinin bid veya ask fiyat\u0131 her de\u011fi\u015fti\u011finde yeni bir veri noktas\u0131 g\u00f6nderilir.<\/p>\n

Bu veriler genellikle JSON format\u0131nda gelir ve a\u015fa\u011f\u0131daki gibi bir yap\u0131ya sahip olabilir:<\/p>\n

\n
\r\n{\r\n    \"symbol\": \"EURUSD\",\r\n    \"bid\": 1.08545,\r\n    \"ask\": 1.08550,\r\n    \"timestamp\": 1678886400000\r\n}\r\n      <\/code><\/pre>\n<\/p><\/div>\n
    Burada symbol<\/code> d\u00f6viz \u00e7iftini, bid<\/code> al\u0131\u015f fiyat\u0131n\u0131, ask<\/code> sat\u0131\u015f fiyat\u0131n\u0131 ve timestamp<\/code> verinin al\u0131nd\u0131\u011f\u0131 zaman\u0131 g\u00f6sterir. Veri sa\u011flay\u0131c\u0131s\u0131na g\u00f6re bu yap\u0131 de\u011fi\u015fiklik g\u00f6sterebilir, ancak temel bilgiler genellikle ayn\u0131d\u0131r. Dinamik abonelik y\u00f6netimi, bu symbol<\/code> alan\u0131na odaklanarak hangi verilerin ak\u0131\u015fa dahil edilece\u011fini kontrol etmeyi ama\u00e7lar.<\/p>\n
Python ile Temel Bir WebSocket Ba\u011flant\u0131s\u0131 Nas\u0131l Kurulur ve Y\u00f6netilir?<\/h2>\n
Python’da WebSocket ba\u011flant\u0131lar\u0131 kurmak ve y\u00f6netmek i\u00e7in en pop\u00fcler k\u00fct\u00fcphane websockets<\/code>‘t\u0131r. Bu k\u00fct\u00fcphane, asenkron (asynchronous) programlamay\u0131 temel al\u0131r, bu da ayn\u0131 anda birden fazla i\u015flemi (\u00f6rne\u011fin, veri alma ve g\u00f6nderme) bloklamadan yapabilmenizi sa\u011flar. Bu b\u00f6l\u00fcmde, bir WebSocket ba\u011flant\u0131s\u0131n\u0131 nas\u0131l kuraca\u011f\u0131n\u0131z\u0131, veri al\u0131p g\u00f6nderece\u011finizi ve temel hata y\u00f6netimini nas\u0131l yapaca\u011f\u0131n\u0131z\u0131 ad\u0131m ad\u0131m inceleyece\u011fiz.<\/p>\n
\u00d6ncelikle, websockets<\/code> k\u00fct\u00fcphanesini y\u00fcklemeniz gerekir:<\/p>\n
\n
\r\npip install websockets\r\n  <\/code><\/pre>\n<\/div>\n
\u015eimdi, basit bir Forex veri ak\u0131\u015f\u0131na ba\u011flanmak i\u00e7in bir \u00f6rnek olu\u015ftural\u0131m. \u00c7o\u011fu finansal veri sa\u011flay\u0131c\u0131s\u0131, belirli bir formatta abonelik mesajlar\u0131 g\u00f6nderilmesini bekler. Genellikle bu bir JSON objesidir ve hangi sembollere abone olmak istedi\u011finizi belirtirsiniz. A\u015fa\u011f\u0131daki \u00f6rnekte, varsay\u0131msal bir veri sa\u011flay\u0131c\u0131n\u0131n WebSocket URL’sini ve abonelik mesaj format\u0131n\u0131 kullanaca\u011f\u0131z. Ger\u00e7ek bir senaryoda, kulland\u0131\u011f\u0131n\u0131z veri sa\u011flay\u0131c\u0131s\u0131n\u0131n (\u00f6rne\u011fin, Binance, Kraken, OANDA gibi platformlar) API belgelerine ba\u015fvurman\u0131z gerekecektir.<\/p>\n
\n
\r\nimport asyncio\r\nimport websockets\r\nimport json\r\n\r\n# Varsay\u0131msal bir WebSocket URL'si ve API anahtar\u0131\r\n# Ger\u00e7ek bir uygulamada, kendi veri sa\u011flay\u0131c\u0131n\u0131z\u0131n URL'sini kullanmal\u0131s\u0131n\u0131z.\r\nWEBSOCKET_URL = \"wss:\/\/stream.example.com\/forex\" \r\n\r\nasync def connect_and_subscribe():\r\n    \"\"\"\r\n    WebSocket'e ba\u011flan\u0131r ve belirli Forex \u00e7iftlerine abone olur.\r\n    Gelen mesajlar\u0131 dinler ve ekrana yazd\u0131r\u0131r.\r\n    \"\"\"\r\n    try:\r\n        async with websockets.connect(WEBSOCKET_URL) as websocket:\r\n            print(f\"WebSocket ba\u011flant\u0131s\u0131 kuruldu: {WEBSOCKET_URL}\")\r\n\r\n            # Abone olmak istedi\u011fimiz semboller\r\n            # Bu, dinamik abonelik y\u00f6netimi i\u00e7in ba\u015flang\u0131\u00e7 noktas\u0131d\u0131r.\r\n            subscription_message = {\r\n                \"action\": \"subscribe\",\r\n                \"symbols\": [\"EURUSD\", \"GBPUSD\"] \r\n            }\r\n            \r\n            # Abonelik mesaj\u0131n\u0131 sunucuya g\u00f6nder\r\n            await websocket.send(json.dumps(subscription_message))\r\n            print(f\"Abonelik iste\u011fi g\u00f6nderildi: {subscription_message}\")\r\n\r\n            # Gelen mesajlar\u0131 s\u00fcrekli dinle\r\n            while True:\r\n                message = await websocket.recv()\r\n                data = json.loads(message)\r\n                print(f\"Al\u0131nan veri: {data}\")\r\n\r\n    except websockets.exceptions.ConnectionClosedOK:\r\n        print(\"WebSocket ba\u011flant\u0131s\u0131 normal \u015fekilde kapat\u0131ld\u0131.\")\r\n    except websockets.exceptions.ConnectionClosedError as e:\r\n        print(f\"WebSocket ba\u011flant\u0131s\u0131 hatayla kapand\u0131: {e}\")\r\n    except Exception as e:\r\n        print(f\"Bir hata olu\u015ftu: {e}\")\r\n\r\nif __name__ == \"__main__\":\r\n    asyncio.run(connect_and_subscribe())\r\n  <\/code><\/pre>\n<\/div>\n
Yukar\u0131daki kod blo\u011fu, asyncio<\/code> k\u00fct\u00fcphanesini kullanarak asenkron bir fonksiyon (connect_and_subscribe<\/code>) tan\u0131mlar. websockets.connect()<\/code> ile belirtilen URL’ye ba\u011flan\u0131r. Ba\u011flant\u0131 kurulduktan sonra, bir JSON mesaj\u0131 olu\u015fturulur ve websocket.send()<\/code> metodu ile sunucuya g\u00f6nderilir. Bu mesaj, hangi Forex \u00e7iftlerine (bu \u00f6rnekte EUR\/USD ve GBP\/USD) abone olmak istedi\u011fimizi belirtir. Ard\u0131ndan, bir while True<\/code> d\u00f6ng\u00fcs\u00fc i\u00e7inde websocket.recv()<\/code> metodu ile sunucudan gelen mesajlar s\u00fcrekli olarak dinlenir. Gelen mesajlar JSON format\u0131ndan Python objesine d\u00f6n\u00fc\u015ft\u00fcr\u00fcl\u00fcr ve ekrana yazd\u0131r\u0131l\u0131r. Hata y\u00f6netimi i\u00e7in try-except<\/code> bloklar\u0131 kullan\u0131lm\u0131\u015ft\u0131r.<\/p>\n
Bu temel yap\u0131, dinamik abonelik y\u00f6netiminin ba\u015flang\u0131\u00e7 noktas\u0131d\u0131r. Mevcut haliyle, kod yaln\u0131zca ba\u015flang\u0131\u00e7ta tan\u0131mlanan sembollere abone olur. Ancak as\u0131l amac\u0131m\u0131z, \u00e7al\u0131\u015fma zaman\u0131nda (runtime) abone olunan sembolleri de\u011fi\u015ftirebilmek ve gereksiz veri ak\u0131\u015f\u0131n\u0131 engellemektir.<\/p>\n
Dinamik Abonelik Y\u00f6netimi: Hangi Forex \u00c7iftlerine \u0130htiyac\u0131m\u0131z Var?<\/h2>\n
Veri ak\u0131\u015f\u0131n\u0131 optimize etmenin anahtar\u0131, yaln\u0131zca o anki stratejiniz veya analiziniz i\u00e7in gerekli olan Forex \u00e7iftlerine abone olmakt\u0131r. Bu, uygulaman\u0131z\u0131n daha az kaynak t\u00fcketmesini, daha h\u0131zl\u0131 \u00e7al\u0131\u015fmas\u0131n\u0131 ve API limitlerine tak\u0131lma riskini azaltmas\u0131n\u0131 sa\u011flar. Dinamik abonelik y\u00f6netimi, bu ihtiyac\u0131 kar\u015f\u0131lamak i\u00e7in geli\u015ftirilen bir yakla\u015f\u0131md\u0131r. Peki, bunu Python ile nas\u0131l ba\u015farabiliriz?<\/p>\n
Dinamik abonelik y\u00f6netimi i\u00e7in temel olarak iki ana mekanizmaya ihtiyac\u0131m\u0131z var:
\n1.  Abonelik \u0130stekleri G\u00f6nderme:<\/strong> Sunucuya yeni bir sembole abone olma veya mevcut bir sembol\u00fcn aboneli\u011fini iptal etme (unsubscribe) iste\u011fi g\u00f6nderebilme yetene\u011fi.
\n2.  Mevcut Abonelikleri Takip Etme:<\/strong> Hali haz\u0131rda hangi sembollere abone oldu\u011fumuzu bilmek, gereksiz abonelik isteklerinin \u00f6n\u00fcne ge\u00e7mek ve abonelik durumunu y\u00f6netmek i\u00e7in \u00f6nemlidir.<\/p>\n
Bu mekanizmalar\u0131 bir araya getiren bir “Abonelik Y\u00f6neticisi” (Subscription Manager) s\u0131n\u0131f\u0131 veya mod\u00fcl\u00fc olu\u015fturabiliriz. Bu y\u00f6netici, WebSocket ba\u011flant\u0131s\u0131 \u00fczerinden abonelik ve abonelikten \u00e7\u0131kma mesajlar\u0131n\u0131 g\u00f6nderecek ve dahili bir veri yap\u0131s\u0131nda (\u00f6rne\u011fin, bir k\u00fcme set<\/code>) mevcut abonelikleri tutacakt\u0131r.<\/p>\n
A\u015fa\u011f\u0131daki \u00f6rnekte, temel bir ForexSubscriptionManager<\/code> s\u0131n\u0131f\u0131 olu\u015fturaca\u011f\u0131z. Bu s\u0131n\u0131f, bir WebSocket ba\u011flant\u0131s\u0131 \u00fczerinden belirli sembollere abone olmay\u0131 ve abonelikten \u00e7\u0131kmay\u0131 y\u00f6netecektir.<\/p>\n
\n
\r\nimport asyncio\r\nimport websockets\r\nimport json\r\n\r\nWEBSOCKET_URL = \"wss:\/\/stream.example.com\/forex\" # Ger\u00e7ek URL'nizi buraya yaz\u0131n\r\n\r\nclass ForexSubscriptionManager:\r\n    def __init__(self, websocket_url):\r\n        self.websocket_url = websocket_url\r\n        self.websocket = None\r\n        self.subscribed_symbols = set() # Abone olunan sembolleri tutan k\u00fcme\r\n        self.data_queue = asyncio.Queue() # Gelen verileri i\u015flemek i\u00e7in kuyruk\r\n\r\n    async def connect(self):\r\n        \"\"\"WebSocket ba\u011flant\u0131s\u0131n\u0131 kurar.\"\"\"\r\n        try:\r\n            self.websocket = await websockets.connect(self.websocket_url)\r\n            print(f\"WebSocket ba\u011flant\u0131s\u0131 kuruldu: {self.websocket_url}\")\r\n            # Veri dinleme g\u00f6revini ba\u015flat\r\n            asyncio.create_task(self._listen_for_data())\r\n        except Exception as e:\r\n            print(f\"Ba\u011flant\u0131 hatas\u0131: {e}\")\r\n            self.websocket = None\r\n\r\n    async def disconnect(self):\r\n        \"\"\"WebSocket ba\u011flant\u0131s\u0131n\u0131 kapat\u0131r.\"\"\"\r\n        if self.websocket:\r\n            await self.websocket.close()\r\n            print(\"WebSocket ba\u011flant\u0131s\u0131 kapat\u0131ld\u0131.\")\r\n            self.websocket = None\r\n\r\n    async def _send_subscription_message(self, action, symbols):\r\n        \"\"\"Abonelik\/abonelikten \u00e7\u0131kma mesaj\u0131n\u0131 sunucuya g\u00f6nderir.\"\"\"\r\n        if not self.websocket:\r\n            print(\"WebSocket ba\u011fl\u0131 de\u011fil, mesaj g\u00f6nderilemiyor.\")\r\n            return\r\n\r\n        message = {\r\n            \"action\": action,\r\n            \"symbols\": list(symbols) # K\u00fcme listeye \u00e7evrilir\r\n        }\r\n        await self.websocket.send(json.dumps(message))\r\n        print(f\"Mesaj g\u00f6nderildi: {message}\")\r\n\r\n    async def subscribe(self, symbols_to_add):\r\n        \"\"\"Yeni sembollere abone olur.\"\"\"\r\n        new_symbols = set(symbols_to_add) - self.subscribed_symbols\r\n        if new_symbols:\r\n            await self._send_subscription_message(\"subscribe\", new_symbols)\r\n            self.subscribed_symbols.update(new_symbols)\r\n            print(f\"Abone olundu: {new_symbols}. Mevcut abonelikler: {self.subscribed_symbols}\")\r\n        else:\r\n            print(\"Belirtilen sembollerden hi\u00e7biri yeni de\u011fil, abonelik yap\u0131lmad\u0131.\")\r\n\r\n    async def unsubscribe(self, symbols_to_remove):\r\n        \"\"\"Belirtilen sembollerin aboneli\u011fini iptal eder.\"\"\"\r\n        existing_symbols = set(symbols_to_remove) & self.subscribed_symbols\r\n        if existing_symbols:\r\n            await self._send_subscription_message(\"unsubscribe\", existing_symbols)\r\n            self.subscribed_symbols.difference_update(existing_symbols)\r\n            print(f\"Abonelikten \u00e7\u0131k\u0131ld\u0131: {existing_symbols}. Mevcut abonelikler: {self.subscribed_symbols}\")\r\n        else:\r\n            print(\"Belirtilen sembollerden hi\u00e7biri abone de\u011fil, abonelik iptali yap\u0131lmad\u0131.\")\r\n\r\n    async def _listen_for_data(self):\r\n        \"\"\"Gelen verileri dinler ve kuyru\u011fa ekler.\"\"\"\r\n        while self.websocket and self.websocket.open:\r\n            try:\r\n                message = await self.websocket.recv()\r\n                data = json.loads(message)\r\n                await self.data_queue.put(data) # Veriyi kuyru\u011fa ekle\r\n            except websockets.exceptions.ConnectionClosedOK:\r\n                print(\"Veri dinleme sonland\u0131r\u0131ld\u0131: Ba\u011flant\u0131 normal \u015fekilde kapat\u0131ld\u0131.\")\r\n                break\r\n            except websockets.exceptions.ConnectionClosedError as e:\r\n                print(f\"Veri dinleme hatas\u0131: {e}\")\r\n                break\r\n            except Exception as e:\r\n                print(f\"Veri i\u015fleme hatas\u0131: {e}\")\r\n                # Hata durumunda ba\u011flant\u0131y\u0131 yeniden kurmay\u0131 d\u00fc\u015f\u00fcnebiliriz\r\n                break\r\n\r\n    async def get_data(self):\r\n        \"\"\"Kuyruktan bir veri al\u0131r.\"\"\"\r\n        return await self.data_queue.get()\r\n\r\nasync def main():\r\n    manager = ForexSubscriptionManager(WEBSOCKET_URL)\r\n    await manager.connect()\r\n\r\n    # Ba\u015flang\u0131\u00e7ta EURUSD ve USDJPY'ye abone olal\u0131m\r\n    await manager.subscribe([\"EURUSD\", \"USDJPY\"])\r\n\r\n    # Bir s\u00fcre veri alal\u0131m\r\n    print(\"\\n--- \u0130lk veri ak\u0131\u015f\u0131 ---\")\r\n    for _ in range(5): # \u0130lk 5 veriyi al\r\n        data = await manager.get_data()\r\n        print(f\"\u0130\u015flenen veri: {data}\")\r\n        await asyncio.sleep(0.5) # Sim\u00fclasyon i\u00e7in bekleme\r\n\r\n    # EURUSD aboneli\u011fini iptal edip GBPUSD'ye abone olal\u0131m\r\n    print(\"\\n--- Abonelik g\u00fcncellemesi ---\")\r\n    await manager.unsubscribe([\"EURUSD\"])\r\n    await manager.subscribe([\"GBPUSD\"])\r\n\r\n    # Yeni aboneliklerle veri almaya devam edelim\r\n    print(\"\\n--- \u0130kinci veri ak\u0131\u015f\u0131 ---\")\r\n    for _ in range(5): # Sonraki 5 veriyi al\r\n        data = await manager.get_data()\r\n        print(f\"\u0130\u015flenen veri: {data}\")\r\n        await asyncio.sleep(0.5)\r\n\r\n    await manager.disconnect()\r\n\r\nif __name__ == \"__main__\":\r\n    asyncio.run(main())\r\n  <\/code><\/pre>\n<\/div>\n
Bu ForexSubscriptionManager<\/code> s\u0131n\u0131f\u0131, a\u015fa\u011f\u0131daki \u00f6nemli \u00f6zellikleri sunar:
\n*   Ba\u011flant\u0131 Y\u00f6netimi:<\/strong> connect()<\/code> ve disconnect()<\/code> metodlar\u0131 ile WebSocket ba\u011flant\u0131s\u0131n\u0131 kurar ve kapat\u0131r.
\n*   Abonelik Takibi:<\/strong> subscribed_symbols<\/code> k\u00fcmesi, mevcut aktif abonelikleri tutar. Bu sayede ayn\u0131 sembole birden fazla kez abone olmaya \u00e7al\u0131\u015fman\u0131n veya abone olunmayan bir sembol\u00fcn aboneli\u011fini iptal etmeye \u00e7al\u0131\u015fman\u0131n \u00f6n\u00fcne ge\u00e7ilir.
\n*   Dinamik Abonelik\/Abonelikten \u00c7\u0131kma:<\/strong> subscribe()<\/code> ve unsubscribe()<\/code> metodlar\u0131, sunucuya uygun JSON mesajlar\u0131n\u0131 g\u00f6ndererek abonelik durumunu g\u00fcnceller. Yaln\u0131zca yeni eklenen veya kald\u0131r\u0131lan semboller i\u00e7in i\u015flem yapar.
\n*   Veri Kuyru\u011fu:<\/strong> asyncio.Queue<\/code> kullanarak gelen verileri ayr\u0131 bir g\u00f6revde dinler (_listen_for_data<\/code>) ve i\u015flenmek \u00fczere bir kuyru\u011fa koyar. Bu, ana uygulaman\u0131n veri alma i\u015flemleri taraf\u0131ndan bloklanmamas\u0131n\u0131 sa\u011flar ve verilerin asenkron olarak i\u015flenmesine olanak tan\u0131r.
\n*   Asenkron \u00c7al\u0131\u015fma:<\/strong> T\u00fcm i\u015flemler asyncio<\/code> ile asenkron olarak y\u00fcr\u00fct\u00fcl\u00fcr, bu da uygulaman\u0131n duyarl\u0131 kalmas\u0131n\u0131 sa\u011flar.<\/p>\n
Bu yap\u0131 sayesinde, stratejiniz de\u011fi\u015ftik\u00e7e veya analiz ihtiya\u00e7lar\u0131n\u0131z evrildik\u00e7e, an\u0131nda farkl\u0131 Forex \u00e7iftlerine abone olabilir veya abonelikten \u00e7\u0131kabilirsiniz. \u00d6rne\u011fin, bir haber olay\u0131 EUR\/USD \u00e7iftini etkiledi\u011finde, yaln\u0131zca bu \u00e7ifte odaklanabilir ve di\u011fer \u00e7iftlerin veri ak\u0131\u015f\u0131n\u0131 ge\u00e7ici olarak durdurarak sistem kaynaklar\u0131n\u0131z\u0131 koruyabilirsiniz.<\/p>\n
Veri Ak\u0131\u015f\u0131n\u0131 Filtreleme ve \u0130\u015fleme Stratejileri: G\u00fcr\u00fclt\u00fcy\u00fc Azaltma Yollar\u0131<\/h2>\n
Dinamik abonelik y\u00f6netimi ile sadece ihtiyac\u0131n\u0131z olan verilere abone olmak b\u00fcy\u00fck bir ad\u0131md\u0131r, ancak gelen veriyi etkili bir \u015fekilde i\u015flemek de ayn\u0131 derecede \u00f6nemlidir. WebSocket \u00fczerinden gelen ger\u00e7ek zamanl\u0131 Forex verileri genellikle \u00e7ok yo\u011fundur ve her tick verisini do\u011frudan kullanmak her zaman verimli de\u011fildir. Bu b\u00f6l\u00fcmde, gelen veri ak\u0131\u015f\u0131n\u0131 daha da optimize etmek ve “g\u00fcr\u00fclt\u00fcy\u00fc” azaltmak i\u00e7in filtreleme ve i\u015fleme stratejilerini inceleyece\u011fiz.<\/p>\n
*   Client Taraf\u0131nda Filtreleme:<\/strong>
\n    Baz\u0131 durumlarda, veri sa\u011flay\u0131c\u0131s\u0131 istedi\u011finiz kadar gran\u00fcler abonelik se\u00e7enekleri sunmayabilir veya bir grup sembole abone olmak durumunda kalabilirsiniz. Bu gibi durumlarda, client (istemci) taraf\u0131nda ek filtreleme yapmak faydal\u0131 olabilir.
\n    \u00d6rne\u011fin, veri sa\u011flay\u0131c\u0131n\u0131z size “t\u00fcm maj\u00f6r \u00e7iftler” i\u00e7in bir abonelik sunuyor olabilir, ancak sizin o an sadece EUR\/USD ve GBP\/USD’ye ihtiyac\u0131n\u0131z var. Sunucu taraf\u0131nda filtreleme yapam\u0131yorsan\u0131z, gelen her verinin symbol<\/code> alan\u0131n\u0131 kontrol ederek sadece ilgilendi\u011finiz \u00e7iftleri i\u015fleyebilirsiniz.<\/p>\n
\n
\r\n    async def _listen_for_data(self):\r\n        # ... (\u00f6nceki kod)\r\n        while self.websocket and self.websocket.open:\r\n            try:\r\n                message = await self.websocket.recv()\r\n                data = json.loads(message)\r\n                \r\n                # Client taraf\u0131 filtreleme \u00f6rne\u011fi: Sadece abone olunan sembolleri i\u015fle\r\n                if data.get(\"symbol\") in self.subscribed_symbols:\r\n                    await self.data_queue.put(data)\r\n                else:\r\n                    # \u0130lgilenilmeyen veriyi yok say\r\n                    # print(f\"Filtrelenen veri (abone olunmayan): {data.get('symbol')}\") \r\n                    pass # G\u00fcr\u00fclt\u00fcy\u00fc azaltmak i\u00e7in bu sat\u0131r\u0131 kullanabiliriz\r\n            except Exception as e:\r\n                # ... (hata y\u00f6netimi)\r\n                pass\r\n      <\/code><\/pre>\n<\/p><\/div>\n
    Bu, sunucu y\u00fck\u00fcn\u00fc azaltmasa da, yerel sisteminizin i\u015f y\u00fck\u00fcn\u00fc ve i\u015fleme karma\u015f\u0131kl\u0131\u011f\u0131n\u0131 azalt\u0131r.<\/p>\n
*   Veri Azaltma (Debouncing ve Throttling):<\/strong>
\n    Forex piyasas\u0131nda fiyatlar saniyede onlarca kez de\u011fi\u015febilir. Her bir tick verisini an\u0131nda i\u015flemek her strateji i\u00e7in gerekli de\u011fildir. Baz\u0131 stratejiler, belirli bir zaman aral\u0131\u011f\u0131nda sadece en son fiyat\u0131 veya belirli bir e\u015fi\u011fin \u00fczerinde de\u011fi\u015fen fiyatlar\u0131 bilmek isteyebilir.
\n    *   Debouncing:<\/strong> Belirli bir olay (\u00f6rne\u011fin, fiyat g\u00fcncellemesi) tetiklendikten sonra belirli bir s\u00fcre (\u00f6rne\u011fin, 100 milisaniye) i\u00e7inde ba\u015fka bir tetikleme olmazsa, olay\u0131 i\u015fler. E\u011fer bu s\u00fcre i\u00e7inde yeni bir olay tetiklenirse, sayac\u0131 s\u0131f\u0131rlar ve tekrar beklemeye ba\u015flar. Bu, h\u0131zl\u0131 ard\u0131\u015f\u0131k olaylarda sadece son olay\u0131 i\u015flemenizi sa\u011flar.
\n    *   Throttling:<\/strong> Belirli bir olay i\u00e7in bir i\u015fleme oran\u0131 s\u0131n\u0131r\u0131 koyar. \u00d6rne\u011fin, saniyede en fazla 1 kez fiyat g\u00fcncellemesi i\u015flersiniz. \u0130lk olay\u0131 i\u015fler, ard\u0131ndan belirli bir s\u00fcre boyunca gelen di\u011fer olaylar\u0131 yok sayar.<\/p>\n
    Python’da asyncio<\/code> ve async_timeout<\/code> gibi k\u00fct\u00fcphanelerle bu t\u00fcr mekanizmalar\u0131 uygulayabilirsiniz. \u00d6rne\u011fin, data_queue<\/code>‘dan veri al\u0131rken bir gecikme ekleyerek throttling yapabilirsiniz:<\/p>\n
\n
\r\n    async def process_data_with_throttle(self, interval=0.1): # 100ms aral\u0131k\r\n        last_processed_time = {}\r\n        while True:\r\n            data = await self.data_queue.get()\r\n            symbol = data.get(\"symbol\")\r\n            current_time = asyncio.get_event_loop().time()\r\n\r\n            if symbol not in last_processed_time or \\\r\n               current_time - last_processed_time[symbol] >= interval:\r\n                print(f\"Throttled \u0130\u015flenen veri: {data}\")\r\n                last_processed_time[symbol] = current_time\r\n            else:\r\n                # print(f\"Throttled: {symbol} verisi atland\u0131.\")\r\n                pass # Veriyi atla\r\n            self.data_queue.task_done()\r\n      <\/code><\/pre>\n<\/p><\/div>\n
    Bu fonksiyon, her sembol i\u00e7in belirli bir aral\u0131kta (interval<\/code>) sadece bir veri noktas\u0131n\u0131n i\u015flenmesini sa\u011flar.<\/p>\n
*   Veri Saklama ve Veritaban\u0131 Entegrasyonu:<\/strong>
\n    Gelen verileri anl\u0131k olarak i\u015flemek yerine, kal\u0131c\u0131 olarak saklamak isteyebilirsiniz. Bu, ge\u00e7mi\u015f fiyat analizleri, backtesting veya raporlama i\u00e7in \u00f6nemlidir. Verileri bir veritaban\u0131na (\u00f6rne\u011fin, PostgreSQL, SQLite, MongoDB) kaydetmek, bu verilerin daha sonra kolayca sorgulanabilmesini ve analiz edilebilmesini sa\u011flar.
\n    Veritaban\u0131na her tick verisini kaydetmek yerine, belirli zaman aral\u0131klar\u0131nda (\u00f6rne\u011fin, her dakika) OHLCC (A\u00e7\u0131l\u0131\u015f, En Y\u00fcksek, En D\u00fc\u015f\u00fck, Kapan\u0131\u015f, Hacim) mum \u00e7ubuklar\u0131 olu\u015fturarak veri miktar\u0131n\u0131 azaltabilirsiniz. Bu, finansal analizde s\u0131k\u00e7a kullan\u0131lan bir y\u00f6ntemdir.<\/p>\n
\n
\r\n    # \u00d6rnek: Basit bir SQLite veritaban\u0131na kaydetme\r\n    import sqlite3\r\n\r\n    async def save_data_to_db(self, data):\r\n        conn = sqlite3.connect(\"forex_data.db\")\r\n        cursor = conn.cursor()\r\n        cursor.execute(\"\"\"\r\n            CREATE TABLE IF NOT EXISTS ticks (\r\n                symbol TEXT,\r\n                bid REAL,\r\n                ask REAL,\r\n                timestamp INTEGER\r\n            )\r\n        \"\"\")\r\n        cursor.execute(\"INSERT INTO ticks (symbol, bid, ask, timestamp) VALUES (?, ?, ?, ?)\",\r\n                       (data[\"symbol\"], data[\"bid\"], data[\"ask\"], data[\"timestamp\"]))\r\n        conn.commit()\r\n        conn.close()\r\n        # Ger\u00e7ek uygulamada, ba\u011flant\u0131 havuzu (connection pool) kullanmak daha verimlidir.\r\n      <\/code><\/pre>\n<\/p><\/div>\n
    Veritaban\u0131na yazma i\u015flemleri de asenkron olarak yap\u0131lmal\u0131 veya ayr\u0131 bir i\u015f par\u00e7ac\u0131\u011f\u0131nda (thread) y\u00fcr\u00fct\u00fclmelidir ki ana WebSocket dinleme g\u00f6revi bloklanmas\u0131n.<\/p>\n
Bu stratejiler, dinamik abonelikle birlikte kullan\u0131ld\u0131\u011f\u0131nda, veri ak\u0131\u015f\u0131n\u0131z\u0131 hem kaynak verimlili\u011fi hem de i\u015fleme etkinli\u011fi a\u00e7\u0131s\u0131ndan \u00f6nemli \u00f6l\u00e7\u00fcde optimize eder.<\/p>\n
Geli\u015fmi\u015f Optimizasyon Teknikleri ve En \u0130yi Uygulamalar: \u00d6l\u00e7eklenebilirlik \u0130\u00e7in \u0130pu\u00e7lar\u0131<\/h2>\n
Dinamik abonelik ve temel filtreleme stratejileriyle \u00f6nemli bir yol kat ettik. Ancak, uygulaman\u0131z b\u00fcy\u00fcd\u00fck\u00e7e ve daha karma\u015f\u0131k hale geldik\u00e7e, daha geli\u015fmi\u015f optimizasyon tekniklerine ve en iyi uygulamalara ihtiya\u00e7 duyacaks\u0131n\u0131z. Bu b\u00f6l\u00fcm, sisteminizin \u00f6l\u00e7eklenebilirli\u011fini, dayan\u0131kl\u0131l\u0131\u011f\u0131n\u0131 ve verimlili\u011fini art\u0131rmak i\u00e7in kullanabilece\u011finiz baz\u0131 ipu\u00e7lar\u0131n\u0131 ve stratejileri kapsar.<\/p>\n
*   Hata Y\u00f6netimi ve Otomatik Yeniden Ba\u011flanma (Reconnection Logic):<\/strong>
\n    WebSocket ba\u011flant\u0131lar\u0131, a\u011f sorunlar\u0131, sunucu bak\u0131m\u0131 veya API limitleri nedeniyle kesilebilir. Sa\u011flam bir uygulama, bu kesintileri zarif\u00e7e ele almal\u0131 ve otomatik olarak yeniden ba\u011flanmaya \u00e7al\u0131\u015fmal\u0131d\u0131r. Yeniden ba\u011flanma stratejisi, genellikle \u00fcstel geri \u00e7ekilme (exponential backoff) algoritmas\u0131 kullan\u0131larak uygulan\u0131r. Bu, yeniden denemeler aras\u0131ndaki bekleme s\u00fcresini her ba\u015far\u0131s\u0131z denemede art\u0131rarak sunucuya a\u015f\u0131r\u0131 y\u00fcklenmeyi \u00f6nler.<\/p>\n
\n
\r\n    import asyncio\r\n    import websockets\r\n    import json\r\n    import time\r\n\r\n    # ... (ForexSubscriptionManager s\u0131n\u0131f\u0131) ...\r\n\r\n    class ForexSubscriptionManager:\r\n        # ... (mevcut init metodu) ...\r\n        def __init__(self, websocket_url):\r\n            self.websocket_url = websocket_url\r\n            self.websocket = None\r\n            self.subscribed_symbols = set()\r\n            self.data_queue = asyncio.Queue()\r\n            self.reconnect_attempts = 0\r\n            self.max_reconnect_attempts = 10\r\n            self.reconnect_delay = 1 # Saniye\r\n            self.is_connected = asyncio.Event() # Ba\u011flant\u0131 durumunu izlemek i\u00e7in\r\n\r\n        async def connect(self):\r\n            \"\"\"WebSocket ba\u011flant\u0131s\u0131n\u0131 kurar ve hata durumunda yeniden ba\u011flan\u0131r.\"\"\"\r\n            while self.reconnect_attempts < self.max_reconnect_attempts:\r\n                try:\r\n                    self.websocket = await websockets.connect(self.websocket_url)\r\n                    print(f\"WebSocket ba\u011flant\u0131s\u0131 kuruldu: {self.websocket_url}\")\r\n                    self.reconnect_attempts = 0 # Ba\u015far\u0131l\u0131 ba\u011flant\u0131da s\u0131f\u0131rla\r\n                    self.is_connected.set() # Ba\u011flant\u0131 kuruldu olarak i\u015faretle\r\n                    # Mevcut abonelikleri yeniden g\u00f6nder\r\n                    if self.subscribed_symbols:\r\n                        await self._send_subscription_message(\"subscribe\", self.subscribed_symbols)\r\n                    asyncio.create_task(self._listen_for_data())\r\n                    return True\r\n                except (websockets.exceptions.ConnectionClosedOK,\r\n                        websockets.exceptions.ConnectionClosedError,\r\n                        OSError) as e:\r\n                    self.reconnect_attempts += 1\r\n                    delay = self.reconnect_delay * (2 ** (self.reconnect_attempts - 1)) # \u00dcstel geri \u00e7ekilme\r\n                    delay = min(delay, 60) # Maksimum 60 saniye bekle\r\n                    print(f\"Ba\u011flant\u0131 hatas\u0131: {e}. Yeniden ba\u011flan\u0131l\u0131yor... ({self.reconnect_attempts}\/{self.max_reconnect_attempts}) {delay:.1f} saniye sonra.\")\r\n                    self.is_connected.clear() # Ba\u011flant\u0131 kesildi olarak i\u015faretle\r\n                    await asyncio.sleep(delay)\r\n                except Exception as e:\r\n                    print(f\"Beklenmedik bir hata olu\u015ftu: {e}\")\r\n                    self.is_connected.clear()\r\n                    break # Di\u011fer hatalarda yeniden denemeyi durdurabiliriz\r\n            print(\"Maksimum yeniden ba\u011flanma denemesi a\u015f\u0131ld\u0131.\")\r\n            return False\r\n\r\n        async def _listen_for_data(self):\r\n            # ... (veri dinleme d\u00f6ng\u00fcs\u00fc) ...\r\n            while self.websocket and self.websocket.open:\r\n                try:\r\n                    # ... (veri alma ve i\u015fleme) ...\r\n                except (websockets.exceptions.ConnectionClosedOK,\r\n                        websockets.exceptions.ConnectionClosedError) as e:\r\n                    print(f\"Veri dinleme hatas\u0131, ba\u011flant\u0131 kapand\u0131: {e}\")\r\n                    self.is_connected.clear()\r\n                    break # Ba\u011flant\u0131 kapand\u0131\u011f\u0131nda d\u00f6ng\u00fcden \u00e7\u0131k\r\n                except Exception as e:\r\n                    print(f\"Veri i\u015fleme s\u0131ras\u0131nda hata: {e}\")\r\n                    # Hata durumunda yeniden ba\u011flanma d\u00f6ng\u00fcs\u00fcne girmek i\u00e7in ba\u011flant\u0131y\u0131 kapat\r\n                    if self.websocket:\r\n                        await self.websocket.close()\r\n                    self.is_connected.clear()\r\n                    break\r\n            # Ba\u011flant\u0131 kesildi\u011finde veya hata oldu\u011funda yeniden ba\u011flanmay\u0131 tetikle\r\n            if not self.is_connected.is_set():\r\n                print(\"Ba\u011flant\u0131 kesildi, yeniden ba\u011flanma deneniyor...\")\r\n                asyncio.create_task(self.connect())\r\n\r\n        # ... (di\u011fer metodlar) ...\r\n      <\/code><\/pre>\n<\/p><\/div>\n
    Bu geli\u015ftirilmi\u015f connect<\/code> ve _listen_for_data<\/code> metodlar\u0131, ba\u011flant\u0131 kesintilerini daha esnek bir \u015fekilde y\u00f6netir ve otomatik yeniden ba\u011flanma denemeleri yapar.<\/p>\n
*   E\u015fzamanl\u0131 \u0130\u015fleme (Concurrent Processing) ve G\u00f6rev Y\u00f6netimi:<\/strong>
\n    Python'\u0131n asyncio<\/code> k\u00fct\u00fcphanesi, e\u015fzamanl\u0131 g\u00f6revleri y\u00f6netmek i\u00e7in m\u00fckemmel bir temel sa\u011flar. Gelen verileri dinlemek, i\u015flemek ve veritaban\u0131na yazmak gibi farkl\u0131 g\u00f6revleri e\u015fzamanl\u0131 olarak \u00e7al\u0131\u015ft\u0131rmak, uygulaman\u0131z\u0131n genel performans\u0131n\u0131 art\u0131r\u0131r. asyncio.create_task()<\/code> kullanarak bu g\u00f6revleri ayr\u0131 ayr\u0131 ba\u015flatabilir ve birbirlerini bloklamalar\u0131n\u0131 engelleyebilirsiniz.
\n    \u00d6rne\u011fin, _listen_for_data<\/code> g\u00f6revi sadece veri almakla ilgilenirken, ba\u015fka bir g\u00f6rev data_queue<\/code>'dan verileri al\u0131p i\u015fleyebilir.<\/p>\n
\n
\r\n    async def main():\r\n        manager = ForexSubscriptionManager(WEBSOCKET_URL)\r\n        await manager.connect()\r\n\r\n        # Veri i\u015fleme g\u00f6revini ba\u015flat\r\n        asyncio.create_task(manager.process_data_with_throttle(interval=0.5)) \r\n        # process_data_with_throttle fonksiyonunu yukar\u0131da tan\u0131mlam\u0131\u015ft\u0131k.\r\n\r\n        await manager.subscribe([\"EURUSD\", \"USDJPY\"])\r\n        await asyncio.sleep(10) # 10 saniye boyunca veri al ve i\u015fle\r\n\r\n        await manager.unsubscribe([\"EURUSD\"])\r\n        await manager.subscribe([\"GBPUSD\"])\r\n        await asyncio.sleep(10) # 10 saniye daha veri al ve i\u015fle\r\n\r\n        await manager.disconnect()\r\n      <\/code><\/pre>\n<\/p><\/div>\n
*   Veri B\u00fct\u00fcnl\u00fc\u011f\u00fc ve S\u0131ralama:<\/strong>
\n    WebSocket \u00fczerinden gelen veriler bazen a\u011f gecikmeleri nedeniyle s\u0131ras\u0131z gelebilir. \u00d6zellikle tick verileri i\u00e7in bu kritik olabilir. Veri sa\u011flay\u0131c\u0131n\u0131z bir s\u0131ralama numaras\u0131 (sequence number) veya zaman damgas\u0131 (timestamp) sa\u011fl\u0131yorsa, bu bilgileri kullanarak verilerin do\u011fru s\u0131rayla i\u015flendi\u011finden emin olmal\u0131s\u0131n\u0131z. E\u011fer s\u0131ras\u0131z veri gelirse, eski veriyi atlamal\u0131 veya tamponlamal\u0131s\u0131n\u0131z.<\/p>\n
*   API Anahtarlar\u0131 ve G\u00fcvenlik:<\/strong>
\n    Finansal veri API'leri genellikle bir API anahtar\u0131 veya kimlik do\u011frulama token'\u0131 gerektirir. Bu bilgileri kodunuzda do\u011frudan sabit kodlamak yerine, ortam de\u011fi\u015fkenleri (environment variables) veya g\u00fcvenli bir yap\u0131land\u0131rma dosyas\u0131 (\u00f6rne\u011fin, .env<\/code> dosyas\u0131) kullanarak y\u00f6netmelisiniz. Bu, kimlik bilgilerinizin g\u00fcvenli\u011fini art\u0131r\u0131r ve kodunuzu daha ta\u015f\u0131nabilir hale getirir.<\/p>\n
*   Yerel Pazar Analizi ve Uygulama:<\/strong>
\n    T\u00fcrkiye'deki yat\u0131r\u0131mc\u0131lar ve geli\u015ftiriciler i\u00e7in bu optimizasyon tekniklerinin \u00f6nemi daha da artmaktad\u0131r. \u00d6zellikle d\u00f6viz kurundaki dalgalanmalar\u0131n y\u00fcksek oldu\u011fu bir ortamda, gecikmesiz ve do\u011fru verilere ula\u015fmak hayati \u00f6nem ta\u015f\u0131r. Yerel arac\u0131 kurumlar\u0131n sundu\u011fu API'leri kullan\u0131rken, onlar\u0131n spesifik limitlerine ve veri formatlar\u0131na dikkat etmek gereklidir. \u00d6rne\u011fin, Borsa \u0130stanbul (BIST) veya di\u011fer yerel finansal kurumlar\u0131n veri ak\u0131\u015flar\u0131 i\u00e7in de benzer WebSocket tabanl\u0131 optimizasyonlar uygulanabilir. Kendi sunucunuzda \u00e7al\u0131\u015fan bir ticaret botu geli\u015ftiriyorsan\u0131z, sunucu kaynaklar\u0131n\u0131n s\u0131n\u0131rl\u0131 olabilece\u011fini g\u00f6z \u00f6n\u00fcnde bulundurarak bu optimizasyonlar sayesinde daha uygun maliyetli sunucular kullanabilirsiniz.<\/p>\n
Bu geli\u015fmi\u015f teknikler ve en iyi uygulamalar, Python ile Forex veri ak\u0131\u015f\u0131 y\u00f6netiminizi bir sonraki seviyeye ta\u015f\u0131yarak daha g\u00fc\u00e7l\u00fc, daha verimli ve daha g\u00fcvenilir bir sistem olu\u015fturman\u0131za yard\u0131mc\u0131 olacakt\u0131r.<\/p>\n
Sonu\u00e7: Ak\u0131ll\u0131 Veri Y\u00f6netimi ile Ticaret Stratejinizi G\u00fc\u00e7lendirin<\/h2>\n
Python ile dinamik Forex \u00e7ifti aboneli\u011fi, sadece bir teknik detay olman\u0131n \u00f6tesinde, ticaret stratejilerinizin ba\u015far\u0131s\u0131 i\u00e7in kritik bir temel olu\u015fturur. Gereksiz veri ak\u0131\u015f\u0131n\u0131 durdurarak sistem kaynaklar\u0131n\u0131z\u0131 korur, API k\u0131s\u0131tlamalar\u0131na tak\u0131lma riskinizi azalt\u0131r ve en \u00f6nemlisi, kararlar\u0131n\u0131z\u0131 daha h\u0131zl\u0131 ve daha do\u011fru bir \u015fekilde alman\u0131z\u0131 sa\u011flayacak temiz ve odaklanm\u0131\u015f bir veri ak\u0131\u015f\u0131 sunar. WebSocket'in \u00e7ift y\u00f6nl\u00fc ileti\u015fim g\u00fcc\u00fcn\u00fc ak\u0131ll\u0131ca kullanarak, yaln\u0131zca ihtiyac\u0131n\u0131z olan bilgilere abone olmak ve bu bilgileri etkin bir \u015fekilde i\u015flemek, hem geli\u015ftirme maliyetlerinizi d\u00fc\u015f\u00fcr\u00fcr hem de uygulaman\u0131z\u0131n performans\u0131n\u0131 maksimize eder. Unutmay\u0131n, finansal piyasalarda her milisaniye \u00f6nemlidir ve do\u011fru veri y\u00f6netimi, rekabet avantaj\u0131 elde etmenizin anahtar\u0131d\u0131r.<\/p>\n
S\u0131k\u00e7a Sorulan Sorular<\/h3>\n