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.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d3a95c59bb7fe2e39ccbbd82e857fe48eedbef5f29cbedfb9e6866e8ea7781ff |
|
MD5 | e383fd83447f45bbc591c26e5c86bb6f |
|
BLAKE2b-256 | afc7a500a0cc49aa05655ca4b8850546c12f6545c701a5604e104ad7d18b8508 |