pyes. Python-elastischer Suchfahrer
Jetzt downloaden

pyes. Ranking & Zusammenfassung

pyes. Stichworte

Suche Python elastisch Elasticsearch Python-Fahrer

pyes. Beschreibung

Python Elasticsearch Treiber pYES ist ein Anschluss zur Verwendung von Elasticsearch python.For jetzt ist es in Alpha-Zustand ist, aber working.ConnectingThese Funktion aus pycassa.Import das Modul wird: >>> import pyesFor eine einzige Verbindung (die _not_ threadsicher ist), Pass eine Liste der Server. >>> client = pyes.connect () # Defaults an den Server zu verbinden at '127.0.0.1:9500' >>> client = pyes.connect ()Framed Transport ist die Standardeinstellung. Sie können es deaktivieren, indem framed_transport = False übergeben. >>> client = pyes.connect (framed_transport = False) Thread-Verbindungen öffnet eine Verbindung für jeden Thread, der eine Elasticsearch Funktion aufruft. Es ist auch balanciert automatisch die Anzahl der Verbindungen zwischen Servern, es sei denn, round_robin Falsch =. >>> client = pyes.connect_thread_local () # Defaults zum Verbinden mit dem Server auf '127.0.0.1:9500' >>> client = pyes.connect_thread_local () # Round-Robin-Verbindungen >>> client = pyes.connect_thread_local (, round_robin = false) # Connect in Liste orderConnections zu Serverausfällen robust sind. Nach einer Unterbrechung, wird es versuchen, jeden Server in der Liste wiederum zu verbinden. Wenn kein Server verfügbar ist, wird es hebt eine NoServerAvailable exception.Timeouts werden ebenfalls unterstützt und soll in der Produktion verwendet werden, um einen Thread zu verhindern, dass das Einfrieren während des Wartens auf Cassandra zurückzukehren. >>> client = pyes.connect (Timeout = 3,5) # 3,5 Sekunden timeout (Machen Sie einige pyes Anrufe und die Verbindung zum Server plötzlich nicht mehr reagiert.) Traceback (jüngste Aufforderung zuletzt): ... pyes.connection.NoServerAvailableNote dass dies nur Griffe Buchse timeouts.UsageCreating eine Verbindung: >>> aus pyes importieren * >>> conn = Elasticsearch ( 'http://127.0.0.1:9200/') Löschen eines Index: >>> try: >>> conn .delete_index ( "test-Index") >>> Ausnahme: >>> Pass (eine Ausnahme fored wird, wenn der Index nicht vorhanden ist) erstellen Sie einen Index: >>> conn.create_index ( "test-Index") eine Zuordnung anlegen : >>> Mapping = {u'parsedtext ': {' boost ': 1,0, >>> 'Index': 'analysiert', >>> 'speichern': 'Ja', >>> 'Typ': u' string '>>> "term_vector": "with_positions_offsets"}, >>> u'name ': {' boost': 1.0 >>> 'index': 'analysiert', >>> 'speichern': yes '>>> 'Typ': u'string', >>> "term_vector": "with_positions_offsets"}, >>> u'title ': {' boost ': 1,0, >>> 'Index':' analysiert '>>> 'speichern': 'ja', >>> 'Typ': u'string', >>> "term_vector": with_po sitions_offsets "}, >>> u'pos ': {' speichern ': 'Ja', >>> 'Typ': u'integer'} >>> u'uuid ': {' boost ': 1,0> >> 'index': 'not_analyzed' >>> 'speichern': 'ja', >>> 'Typ': u'string '}} >>> conn.put_mapping ( "test-Typ", {' Eigenschaften : Mapping} ) Index einige Dokumente: >>> conn.index ({ "name": "Joe Tester", "parsedtext": "Joe Testere netter Kerl", "uUID": 11111" , "Position": 1}, "test-Index", "Test-Typ", 1) >>> conn.index ({ "name": "Bill Quatsch", "parsedtext": "Joe Testere nice guy , "UUID": "22222", "Position": 2}, "Test-Index", "Test-type", 2) aktualisieren eines Index: >>> conn.refresh () Führen Sie eine Abfrage >>> q = Termquery ( "name", "joe") >>> result = self.conn.search (query = q) weitere Beispiele Blicke auf die Tests. Anforderungen: · Python Was ist neu in dieser Version: · Added Server Info zu sammeln. · Version 0.12 oder höher erforderlich. Feste Befestigung Plugin. Aktualisiert Masseneinfügung neue api zu verwenden. Hinzugefügt Facette Unterstützung (außer Geotypen). Hinzugefügt Fluss Unterstützung. einige Verfahren Cleanup. Hinzugefügt default_indexes variabel. Datetime Deserialisierung hinzugefügt. Verbesserte Leistung und Speichernutzung in Bulk-Liste mit StringIO ersetzen. Anfängliche Ausbreitung von Elasticsearch Ausnahme von Python.

pyes. Zugehörige Software