Python-Implementierungsbeispiel für die Verbindung mit Phoenix

Dieser Artikel stellt hauptsächlich die Methode zum Verbinden von Phoenix mit Python vor, erläutert kurz das Konzept und die Funktionen von Phoenix und analysiert die damit verbundenen Bedienfähigkeiten von Python, die Phoenix anhand spezifischer Beispiele verbinden

Das Beispiel in diesem Artikel beschreibt, wie man Phoenix mit Python verbindet. Teilen Sie es als Referenz mit allen. Die Details lauten wie folgt:

phoenix ist ein Open-Source-Projekt von saleforce.com und wurde später an Apache gespendet. Es entspricht einer Java-Middleware, die Entwicklern hilft, z. B. die Verwendung von JDBC für den Zugriff auf relationale Datenbanken und die NoSql-Datenbank HBase. Phoenix kann lediglich als Tool angesehen werden, das die Syntax von HBase ersetzt. Obwohl Sie Java oder JDBC verwenden können, um eine Verbindung zu Phoenix herzustellen und dann HBase zu betreiben, kann es nicht in OLTP in einer Produktionsumgebung verwendet werden.

1. Lösung

Hier verbinden wir uns über Jpype und JayDeBeApi

2. Prozess

Hier liste ich den Beispielcode auf:

import jpype
import jaydebeapi
import os
phoenix_client_jar="/data/users/huser/phoenix/phoenix-4.3.0-client.jar"
args=='-Djava.class.path=%s'% phoenix_client_jar
jvm_path=jpype.getDefaultJVMPath()
jpype.startJVM(jvm_path,args)
conn=jaydebeapi.connect('org.apache.phoenix.jdbc.PhoenixDriver',['jdbc:phoenix:bj-g2hdp1,bj-g2hdp2,bj-g2hdp3:2181','',''],phoenix_clinent_jar)
curs=conn.cursor()
sql="select * from test"
count=curs.execute(sql)
results=curs.fetchall()
for r in results:
  print r

Das obige ist der detaillierte Inhalt vonPython-Implementierungsbeispiel für die Verbindung mit Phoenix. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!