将数据源添加到 blaze 服务器
add data sources to blaze server
我想要 运行 一台安装两个数据源的 blaze 服务器,一个 postgreSQL table 和一个 CSV 文件,但我不知道如何在 blaze 服务器上安装多个数据源.
我在服务器端有以下代码:
engine = create_engine('postgresql://user:pass@localhost:5432/mydb')
with engine.connect() as conn:
metadata=MetaData()
metadata.bind=engine
t=Table('t', metadata, autoload=True, autoload_with=conn)
server=bz.Server(t)
server.run(host='0.0.0.0', port=6363)
在客户端:
source =Data('blaze://localhost:6363/')
t=symbol('t', source.dshape)
expr=t[t.color=='K']
result=compute(expr, Data(source))
如何在同一个 blaze 服务器上安装另一个数据源,如 CSV 文件或另一个 table 数据库?
例如:
csv= Data('.\data.csv', sep=';', has_header=True)
更新:
我必须将数据源作为字典添加到我的服务器,
engine = create_engine('postgresql://qfsa:123@localhost:5433/mydb')
with engine.connect() as conn:
metadata=MetaData()
metadata.bind=engine
table1=Data(Table('tablename1', metadata, autoload=True, autoload_with=conn))
table2=Data(Table('tablename2', metadata, autoload=True, autoload_with=conn)
csvfile=Data('.\data.csv', sep=';', has_header=True)
resources={
'table1': table1,
'table2': table2,
'csvfile': csvfile
}
我从这里得到了这个问题的答案:
https://github.com/blaze/blaze/issues/1631
执行此操作的标准方法是使服务器资源成为其他资源的字典。我更新了问题。
我想要 运行 一台安装两个数据源的 blaze 服务器,一个 postgreSQL table 和一个 CSV 文件,但我不知道如何在 blaze 服务器上安装多个数据源.
我在服务器端有以下代码:
engine = create_engine('postgresql://user:pass@localhost:5432/mydb')
with engine.connect() as conn:
metadata=MetaData()
metadata.bind=engine
t=Table('t', metadata, autoload=True, autoload_with=conn)
server=bz.Server(t)
server.run(host='0.0.0.0', port=6363)
在客户端:
source =Data('blaze://localhost:6363/')
t=symbol('t', source.dshape)
expr=t[t.color=='K']
result=compute(expr, Data(source))
如何在同一个 blaze 服务器上安装另一个数据源,如 CSV 文件或另一个 table 数据库? 例如:
csv= Data('.\data.csv', sep=';', has_header=True)
更新:
我必须将数据源作为字典添加到我的服务器,
engine = create_engine('postgresql://qfsa:123@localhost:5433/mydb')
with engine.connect() as conn:
metadata=MetaData()
metadata.bind=engine
table1=Data(Table('tablename1', metadata, autoload=True, autoload_with=conn))
table2=Data(Table('tablename2', metadata, autoload=True, autoload_with=conn)
csvfile=Data('.\data.csv', sep=';', has_header=True)
resources={
'table1': table1,
'table2': table2,
'csvfile': csvfile
}
我从这里得到了这个问题的答案:
https://github.com/blaze/blaze/issues/1631
执行此操作的标准方法是使服务器资源成为其他资源的字典。我更新了问题。