txconnpool.

Eine generalisierte Verbindung zwischen Verdrehungen
Jetzt downloaden

txconnpool. Ranking & Zusammenfassung

Anzeige

  • Rating:
  • Lizenz:
  • The Apache License 2.0
  • Preis:
  • FREE
  • Name des Herausgebers:
  • Eric Florenzano
  • Website des Verlags:
  • http://code.google.com/u/floguy/

txconnpool. Stichworte


txconnpool. Beschreibung

Eine generalisierte Anschluss-Bündelbibliothek für verdreht TXCONPOOL ist eine verallgemeinerte Anschluss-Bündelbibliothek für Twisted.Example BeschreibungWeum, die wir mit einer Webanwendung erhalten haben, die teure Berechnungen ausführt und sie dann in einem memcached-Server speichert. Der einfache Weg, um dies in Twisted zu erreichen, besteht darin, einen ClientCreator für das MemcacheProtokoll zu erstellen, und wann immer wir mit dem Server kommunizieren müssen, können wir einfach das verwenden. Diese Werke für niedrige Abfragen, aber sagen wir, dass wir jetzt anfangen, Memcached a zu schlagen Viele - mehrmals pro Webanfrage, von denen wir viele pro Sekunde erhalten. Sehr schnell kann der Verbindungsaufwand zu einem Problem werden. Warteschlangen von Abfragen, wenn alle Anschlüsse verwendet werden. Mit TXCONNPOOL kann das Festlegen dieses Updates sehr einfach sein , Poolclass PooledMemcacheProtokoll (MemcacheProtocol): "" Ein MemcacheProtokoll, mit dem eine Verbindungspool informiert ist, die er bereit ist, Anforderungen anzunehmen. "" Factory = none def connectionmade (self): "" "Benachrichtigen Sie unsere Fabrik, die wir annehmen können Anschlüsse. PooledClientFactory): Protokoll = PooledMemcacheProtocolclass MemcachEpool (Pool): clientFactory = memcacheclientFactory def (self, * args, ** kwargs): Return self.performrequest ('Get', * args, ** kwargs) def selbst, * args, ** kwargs): return self.performrequest ('set', * args, ** kwargs) def löschen (self, * args, ** kwargs): return self.performrequest ('löschen', * args , ** kwargs) def add (self, * args, ** kwargs): return self.performrequest ('add', * args, ** kwargs) Nun können wir mit diesem erstellt und diese einsetzen: Von Twisted.Internet.address Importieren IPv4AddressAddr = IPv4Address ('TCP', '127.0.0.1', 11211) MC_POOL = MemcachePool (addr, maxclients = 20) d = mc_pool.get ('Cached-Data') def gotcacheddata (Daten) : Flags, Wert = Daten Wenn Wert: drucken 'yay, wir haben einen Cache-Treffer' else: drucken 'boo, es war ein Cache-Cache-Anforderungen: · Python · Verdrehte


txconnpool. Zugehörige Software

redis_queue.

Eine persistente, (meist) atomare Warteschlange (wie Diskette oder Warteschlange) implementiert mit Redis-Backing ...

132

Herunterladen