Hier Code:Hive - Python Verbindungsfehler
#!/usr/bin/env python
import pyhs2
try:
with pyhs2.connect(host='localhost',
port=10001,
authMechanism="PLAIN",
user='root',
password='test',
database='test') as conn:
with conn.cursor() as cur:
#Show databases
print cur.getDatabases()
#Execute query
cur.execute("select * from raw_stats")
#Return column info from query
print cur.getSchema()
#Fetch table results
for i in cur.fetch():
print i
except Thrift.TException, tx:
print '%s' % (tx.message)
Fehler!
Traceback (jüngste Aufforderung zuletzt): File "/usr/local/py/test.py", Zeile 8, in database = 'default') als conn: Datei „/ usr/lib /python2.6/site-packages/pyhs2/ init .py ", Zeile 7, in verbinden return Verbindung (* args, ** kwargs) Datei" /usr/lib/python2.6/site-packages/ pyhs2/connections.py“, Zeile 46, in init transport.open() Datei "/usr/lib/python2.6/site-packages/pyhs2/cloudera/thrift_sasl.py", line 55, in offen self._trans.ope n() Datei "/usr/lib64/python2.6/site-packages/thrift/transport/TSocket.py", Linie 101, in offener message = Nachricht) thrift.transport.TTransport.TTransportException: Kann keine Verbindung zu localhost: 10001
Sein gelöst durch hiveServer2 Dienst starten und den Port 10000 ändern –