Baisse des performances Websocket avec des threads supplémentaires

Je suis nouveau sur les websockets / threading et j'aimerais de l'aide pour déboguer un problème de performances que je rencontre avec les websockets. Voir mon code ci-dessous - si j'inclus les threads supplémentaires - mes performances websocket seront affectées. Si je supprime les threads, les performances du websocket seront vraiment bonnes. Comment puis-je conserver les threads ET conserver de bonnes performances Websocket ? Dois-je ajuster la priorité de mes threads ou quelque chose... ?

import websocket
import threading
import json
import datetime
class Trading():
 # Stores the message in memory
 def on_message_binance(self, ws, message):
 #print(message)
 self.message = message
 def start(self):
 self.tower = []
 binance_stream = dict()
 binance_stream['BTC'] = 'wss://stream.binance.com:9443/stream?streams=btcusdt@trade'
 threads = dict()
 self.message = ''
 threads['ws'] = websocket.WebSocketApp(binance_stream['BTC'],
    on_message=lambda ws, msg: self.on_message_binance(self, ws, msg))
 # Launch the thread
 threads['thread'] = threading.Thread(target=threads['ws'].run_forever, name='BTC')
 threads['thread'].daemon = True
 threads['thread'].start()
 # ************************************************
 # IF THESE LINES ARE INCLUDED - WEBSOCKETS WILL BE DELAYED. COMMENT OUT TO REMOVE DELAYS
 for x in range(20):
 threads[x] = threading.Thread(target=self.wheee, args=(self, 1), name=x)
 threads[x].daemon = True
 threads[x].start()
 # ************************************************
 prior_binmsg = ''
 while True:
 # Ensure that you don't continously read the same message over and over again
 binmsg = self.message
 if (binmsg!= prior_binmsg):
 prior_binmsg = binmsg
 binancemsg = json.loads(binmsg)
 curtime_GMT = datetime.datetime.now().timestamp()
 timestamp = float(binancemsg['data']['T'])/1000
 delay = curtime_GMT - timestamp
 print('Websocket delay = ' + str(delay))
 def wheee(self, num):
 import time
 while True:
 wheeeeeeee = num
if __name__ == '__main__':
 # Start trading!
 x = Trading
 x.start(x)


Solution du problème

Vous lancez un tas de threads qui ont self.wheeepour cible, qui est unwhile True boucle qui ne fait rien d'utile

Commentaires

Enregistrer un commentaire

Posts les plus consultés de ce blog

Comment signer la connexion OKEx API version 5 avec websockets ?

Bien que cette question ait reçu une réponse pour les versions précédentes de l'API OKEx utilisant REST, elle ne l'a pas été pour la dernière version 5 de l'API utilisant des websockets. Les docs sont ici. Je reçois l'erreur suivante {"event":"error","msg":"Invalid sign","code":"60007"} , il doit donc y avoir un problème avec l'algorithme de chaîne de signature, mais je n'arrive pas à identifier où je fais une erreur. import hmac import json import time import hashlib import asyncio import websockets passphrase = "XXXX" secret_key = b"XXXX" api_key = "XXXX" timestamp = int(time.time()) print("timestamp: " + str(timestamp)) sign = str(timestamp) + 'GET' + '/users/self/verify' total_params = bytes(sign, encoding= 'utf-8') signature = hmac.new(bytes(secret_key, encoding= 'utf-8'), total_params, digestmod=hashlib.sha256).digest() sign...
Lire la suite

La fonction GCP Cloud pour écrire des données dans BigQuery s'exécute avec succès, mais les données n'apparaissent pas dans la table BigQuery

Image
J'exécute la fonction cloud suivante. Il s'exécute avec succès et indique que les données ont été chargées dans la table. Mais lorsque j'interroge BigQuery, aucune donnée n'a été ajoutée. Je ne reçois aucune erreur et aucune indication que cela ne fonctionne pas. from google.cloud import bigquery import pandas as pd def download_data(event, context): df = pd.read_csv('https://covid.ourworldindata.org/data/ecdc/full_data.csv') # Create an empty list Row_list =[] # Iterate over each row for index, rows in df.iterrows(): # Create list for the current row my_list =[rows.date, rows.location, rows.new_cases, rows.new_deaths, rows.total_cases, rows.total_deaths] #print(my_list) # append the list to the final list Row_list.append(my_list) ## Get Biq Query Set up client = bigquery.Client() table_id = "<project_name>.raw.daily_load" table = client.get_table(table_id) print(client) print(table_id) print(table) errors = client.insert_rows(...
Lire la suite

Erreur Symfony : "Une exception a été levée lors du rendu d'un modèle"

j'essaie d'inclure <link href="{{ asset('css/mystyle.css') }}" rel="stylesheet"/> dans mon fichier twig et le rendre. Mais cela me donne une exception PHP non interceptée Twig_Error_Runtime : "Une exception a été levée lors du rendu d'un modèle ("Le fichier manifeste de l'actif "/../public/build/manifest.json" n'existe pas.") ça marche quand j'utilise link href="css/mystyle.css" rel="stylesheet"/> . Voici mon contrôleur: <?php namespace App\Controller; use Symfony\Component\Routing\Annotation\Route; use Symfony\Bundle\FrameworkBundle\Controller\AbstractController; use Symfony\Component\HttpFoundation\Response; class WelcomeController extends AbstractController { /** * @Route("/", name="welcome") */ public function index() { return $this->render('welcome/index.html.twig'); } } Voici mon modèle de brindille : <!doctype html> ...
Lire la suite