63 lines
1.2 KiB
Python
63 lines
1.2 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: UTF-8 -*-.
|
|
|
|
from sqlalchemy import create_engine, text
|
|
from sqlalchemy.engine import URL
|
|
from datetime import datetime as dt
|
|
import pandas as pd
|
|
import geopandas as gpd
|
|
|
|
|
|
# zones_humides / ps
|
|
schema = 'zones_humides'
|
|
|
|
# Parametres bdd
|
|
user = 'cen_admin'
|
|
pwd = '#CEN38@venir'
|
|
adr = '91.134.194.221'
|
|
port = '5432'
|
|
base = 'azalee'
|
|
|
|
url = URL.create('postgresql+psycopg2',
|
|
username=user,
|
|
password=pwd,
|
|
host=adr,
|
|
database=base,
|
|
)
|
|
con_azalee = create_engine(url)
|
|
# Parametres bdd
|
|
user = 'Admin_CENI'
|
|
pwd = 'yatIv5quoop+'
|
|
adr = 'database.carmencarto.fr'
|
|
port = '5432'
|
|
base = 'CENI'
|
|
|
|
url = URL.create('postgresql+psycopg2',
|
|
username=user,
|
|
password=pwd,
|
|
host=adr,
|
|
database=base,
|
|
)
|
|
con_carmen = create_engine(url)
|
|
|
|
if schema == 'ps':
|
|
table = 'v_pelouseseches'
|
|
elif schema == 'zones_humides':
|
|
table = 'v_zoneshumides'
|
|
|
|
today = dt.now()
|
|
|
|
sql = 'SELECT * FROM %s.%s' % (schema,table)
|
|
vue = gpd.read_postgis(sql,con_azalee)
|
|
vue.to_postgis(
|
|
name=table,
|
|
con=con_carmen,
|
|
# schema=schema,
|
|
if_exists='replace',
|
|
index=False,
|
|
# geom_col='geom'
|
|
)
|
|
|
|
comment = "COMMENT ON TABLE %s IS 'LAST UPDATE : %s'" % (table,today)
|
|
with con_carmen.begin() as cnx:
|
|
cnx.execute(comment) |