如何解决在带有PyDrill的Apache Drill中使用SQL组合
是否可以在Apache Drill中使用SQL组合?
对于SQL数据库,使用psycopg2
就像
from psycopg2 import sql
import psycopg2
connection = psycopg2.connect(host = "127.0.0.1",port = "5432",database = "postgres")
cursor = connection.cursor()
template = """
SELECT *
FROM {schema}.{tablename}
LIMIT 5;
"""
params = {
"schema": sql.Identifier("myschema"),"tablename": sql.Identifier("mytable")
}
qry = sql.SQL(template).format(**params)
cursor.execute(qry)
res = cursor.fetchall()
print(res)
我正在尝试使用以下代码在Apache Drill中执行相同的操作,并使用PyDrill
作为连接器,但是收到SerializationError
错误。
# SQL Composition with DRILL
from psycopg2 import sql
from pydrill.client import PyDrill
drill = PyDrill(host='localhost',port=8047)
template="""SELECT *
FROM {tablename}
LIMIT 5"""
params = {
"tablename": sql.Identifier("dfs.`/Users/user/file.parquet`")
}
qry = sql.SQL(template).format(**params)
drill.query(qry)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。