Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

How do I access and query a HDFS table from Python?

avatar
New Contributor

Hello,
I have looked all over the internet and couldn't arrive at a neat solution.

Scenario:
I have hiveserver2 running in my company's QA environment. I am able to ssh into the env and perform queries on tables in HDFS using Hive. I inspected hive-site.xml in QA and found that it uses kerberos authentication. I would now like to execute queries programmatically using Python from my local machine for experimentation. I have come across PyHive and Beeline.

My biggest hurdle is that I cannot find the JDBC url or IP address of the hiveserver2. Where can I get this information?

I used the IP address of my QA env (ifconfig) in my Python script and it couldn't connect to hiveserver2.

Is there any other workaround for accessing the tables in HDFS from Python?

4 REPLIES 4

avatar
Rising Star

avatar
New Contributor

As mentioned in my question. I have already tried using PyHive.

avatar
Expert Contributor

You can get the url from the Hive, Summary page in Ambari. For a Kerberized cluster, you will need to cal kinit to get a ticket before launching the python program. The format of the connection string for kerberos is something like the following. The actual user principal (and authentication) will be taken from the Kerberos ticket. Test the connection string with Beeline to make sure it works.

beeline -u "jdbc:hive2://myhs2.foo:10000/default;principal=hive/myhs2@foo@MYKERBREALM;auth=kerberos"

avatar
Contributor

Hi @vignesh_radhakr .

 

you can simply access your hive by using below :-

URL:-

conn = hive.Connection(host="masterIP", port=10000, username="cdh123")

note:- MasterIP need to pass with port 10000

 

Thanks

HadoopHelp