feapder pipelines extension
Project description
FEAPDER 管道扩展
简介
此模块为feapder
的pipelines
扩展,感谢广大开发者对feapder
的贡献
随着feapder支持的pipelines越来越多,为减少feapder的体积,特将pipelines提出,使用者可按需安装
管道
PostgreSQL
贡献者:沈瑞祥
安装
pip install feapder_pipelines[pgsql]
使用
在feapder
项目的setting.py
中使用如下配置
# PostgreSQL
PGSQL_IP =
PGSQL_PORT =
PGSQL_DB =
PGSQL_USER_NAME =
PGSQL_USER_PASS =
ITEM_PIPELINES = [
"feapder_pipelines.pipelines.pgsql_pipeline.PgsqlPipeline"
]
细节
注:入库时 ON CONFLICT(key) 默认为id或通过如下sql查出来的第一个值select column_names from(
select
t.relname as table_name,
i.relname as index_name,
array_to_string(array_agg(a.attname), ', ') as column_names
from
pg_class t,
pg_class i,
pg_index ix,
pg_attribute a
where
t.oid = ix.indrelid
and i.oid = ix.indexrelid
and a.attrelid = t.oid
and a.attnum = ANY(ix.indkey)
and t.relkind = 'r'
and t.relname like '%'
group by
t.relname,
i.relname
order by
t.relname,
i.relname) as res
where table_name = 'table_name';
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for feapder_pipelines-1.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ace076e28c937634db755bab512571f4aa1f2739c60ae892ab844efe436e9390 |
|
MD5 | 29b999565c5871bd93254f309d352dea |
|
BLAKE2b-256 | f785489b0ba081da694bda7f1bea9b97253a716ec9356a592442f227e2b4acb3 |