将Teradata查询读入Pandas

是否有人找到了将Teradata查询读入Pandas数据框的方法？它看起来像SQLAlchemy没有Teradata方言。将Teradata查询读入Pandas

2016-01-22 atm

也许看看这个：https://github.com/grisaitis/sqlalchemy-teradata – joris

看起来很有前途，但不幸的是它是为Python 3编写的 – atm

我做到了用read_sql。下面ID代码剪断：

def dqm() : 
    conn_rw = create_connection() 
    dataframes = [] 
    srcfile = open('srcqueries.sql', 'rU').read() 
    querylist = srcfile.split(';') 
    querylist.pop() 
    for query in querylist : 
     dataframes.append(pd.read_sql(query, conn_rw)) 
    close_connection(conn_rw) 
    return dataframes,querylist

您可以创建连接如下：

def create_connection(): 
     conn = pyodbc.connect("DRIVER=Teradata;DBCNAME=tddb;UID=uid;PWD=pwd;QUIETMODE=YES", autocommit=True,unicode_results=True) 
     return conn

你可以在这里查看完整代码：GitHub Link 让我知道如果这个回答您的查询。

来源

2016-01-23 17:50:59 minatverma

感谢您的答案！所以你使用pyodbc而不是sqlalchemy来创建连接，对吧？ – atm

对。如果您打算安装它们，我建议您使用brew包管理器。 – minatverma

您可以使用slqalchemy，但您也需要安装sqlalchemy-teradata。你可以做到这一点通过PIP

pip install sqlachemy-teradata

代码的其余部分保持不变:)

from sqlalchemy import create_engine 
import pandas as pd 

user, pasw, host = 'username','userpass', 'hostname' 

# connect 
td_engine = create_engine('teradata://{}:{}@{}:22/'.format(user,pasw,hostname)) 

# execute sql 
query = 'select * from dbc.usersV' 
result = td_engine.execute(query) 

#To read your query to Pandas 
df = pd.read_sql(query,td_engine)

来源

2017-10-02 10:20:06

将Teradata查询读入Pandas

回答

相关问题