python 往oracle里面写DataFrame(二)
2019-05-15 18:25
676 查看
之前写了python 往oracle里面DataFrame, 在自己的笔记本上奏效,但是放在集群上去,就会失效了,报错内容为:
sqlalchemy.exc.DatabaseError: (cx_Oracle.DatabaseError) ORA-12505: TNS: 监听程序当前无法识别连接描述符中所给出的 SID
解决方案为创建引擎的方式有所变化,具体的代码入下
from sqlalchemy.dialects.oracle import \ BFILE, BLOB, CHAR, CLOB, DATE, \ DOUBLE_PRECISION, FLOAT, INTERVAL, LONG, NCLOB, \ NUMBER, NVARCHAR, NVARCHAR2, RAW, TIMESTAMP, VARCHAR, \ VARCHAR2 def mapping_df_types(df): dtypedict = {} for i, j in zip(df.columns, df.dtypes): if "object" in str(j): dtypedict.update({i: VARCHAR(256)}) if "float" in str(j): dtypedict.update({i: NUMBER(19,8)}) if "int" in str(j): dtypedict.update({i: VARCHAR(19)}) return dtypedict ## 往集群oracle写入数据 def put_df_toOracle_cluster(df_data , tableName , ip , port ,uname,pwd , tnsname): import cx_Oracle as cx_Oracle from sqlalchemy import create_engine # ip = 'localhost' # port = '1521' # uname = 'chensq' # 用户名 # pwd = '123456' # 密码 # tnsname = 'orcl' # 实例名 dsnStr = cx_Oracle.makedsn(ip, port, service_name=tnsname) connect_str = "oracle://%s:%s@%s" %(uname, pwd, dsnStr) engine = create_engine(connect_str, encoding=encoding) from sqlalchemy.dialects.oracle import \ BFILE, BLOB, CHAR, CLOB, DATE, \ DOUBLE_PRECISION, FLOAT, INTERVAL, LONG, NCLOB, \ NUMBER, NVARCHAR, NVARCHAR2, RAW, TIMESTAMP, VARCHAR, \ VARCHAR2 dtypedict = mapping_df_types(df_data) print(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>开始") print(dtypedict) print(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>结束") df_data.to_sql(tableName,engine,index=False,if_exists='append',dtype=dtypedict,chunksize=None) #------------------------------
参考博客为:
【1】https://blog.csdn.net/AlanGuoo/article/details/88255194
【2】: https://blog.csdn.net/walking_visitor/article/details/84023393
相关文章推荐
- [置顶] 【python DataFrame】Pandas里面的屠龙宝刀DataFrame
- python之pandas的基本使用-series和dataframe(1)
- 利用python将所有时序NDVI影像转换为DataFrame数据并进行归一化
- Python DataFrame 设置输出不显示index(索引)值的方法
- python pandas dataframe to_sql方法error及其解决
- python pandas.DataFrame选取、修改数据最好用.loc,.iloc,.ix
- python pandas dataframe 小结(包括集合set)
- Python中pandas dataframe删除一行或一列:drop函数
- python 的pandas DataFrame大全
- python pandas dataframe
- [cx_oralce]加速批量插入dataframe到oracle
- The CURD(增删查改) operation of DataFrame in python[Create]
- 使用 MySQLdb 从数据库拉回数据,并将数据存入 python的DataFrame中
- Dataframe花样切片~(Python)
- 2017.06.15-2016.06.18回顾 loc/iloc/ix dataframe相关 oracle无自增去重 correl
- Python数据科学之DataFrame的IO操作
- Python - pandas DataFrame 数据选取,修改,切片
- python 之expenduser,dataframe.apply,np.fromstring
- python 处理dataframe中的时间字段方法
- Python pandas.DataFrame调整列顺序及修改index名