今天看啥
    热点:

      天发国际娱乐官网:不过伴随南航与南师的话题永远污力滔滔啊......南师回应道:表白可以,但我不接受异地恋。

      通过Python脚本将DMP文件写入AWS RDS oracle中,pythonaws


      由于RDS(oracle)不直接支持SSH,FTP(基于安全因素吧).所以原有系统expdp或exp出来的dmp文件,不能直接导入到RDS中。官方文档里建议通过networklink或者dblink的方式 从原有数据库迁移到RDS,考虑到网络和安全因素,此方法暂被忽略掉。

      查找各种文档发现,可以通过Oracle自身的UTL_FILE包来写dmp文件到RDS的文件夹里,读取EC2里的本地文件部分通过Python脚本实现,这样变相实现了,从EC2本地上传到RDS的功能。

      代码如下:

      def cpy_to_rds():
          file_name = 'test4.dmp'
          src_name = 'c:/testdata/test4.dmp'
          #在RDS,DATA_PUMP_DIR下新建或者覆盖一个空文件
          UTL_FILE_NEW_FILE = "DECLARE fi UTL_FILE.FILE_TYPE; BEGIN fi:=UTL_FILE.fopen('DATA_PUMP_DIR','{0}','wb',32766); UTL_FILE.fclose(fi); END;"
          #写入RDS
          UTL_FILE_CREATE_FILE = "DECLARE " \
                                 "fi UTL_FILE.FILE_TYPE; " \
                                 "v_buffer RAW(32760); " \
                                 "BEGIN " \
                                 "v_buffer:= hextoraw('{1}') ; " \
                                 "fi:=UTL_FILE.fopen('DATA_PUMP_DIR','{0}','ab');" \
                                 "UTL_FILE.put_raw(fi,v_buffer);" \
                                 "UTL_FILE.fclose(fi); " \
                                 "END;"
      
          con = cx_Oracle.connect('User/[email protected]')
          cur = con.cursor()
          # 在RDS,DATA_PUMP_DIR下新建或者覆盖一个空文件
          cur.execute(UTL_FILE_NEW_FILE.format(file_name))
          chunk = 3000
          f = open(src_name, 'rb')
          line = f.read(chunk)
          # 写入RDS
          cur.execute(UTL_FILE_CREATE_FILE.format(file_name, line.hex()))
          while (len(line)) > 0:
              line = f.read(chunk)
              # 写入RDS
              cur.execute(UTL_FILE_CREATE_FILE.format(file_name, line.hex()))
          cur.close()
          con.close()

      需要注意的是chunk设置不能为32760。

      UTL_FILE_CREATE_FILE语句也可以转换为RDS中的一个Function函数:

      create or replace function gen_dmp(i_name IN VARCHAR2, i_buffer IN RAW ) return varchar2 is
      begin
      declare
      v_file  utl_file.file_type;
      begin
      v_file:=utl_file.fopen('DATA_PUMP_DIR',i_name,'ab');
      utl_file.put_raw(v_file,i_buffer);
      utl_file.fclose(v_file);
      return 'OK';
      end;
      end;

      在Python中调用此函数,这样chunk就可以设置到32767最大值了.

      def cpy_to_rds_func():
          file_name = 'tes4.dmp'
          src_name = 'c:/testdata/test4.dmp'
          UTL_FILE_NEW_FILE = "DECLARE fi UTL_FILE.FILE_TYPE; BEGIN fi:=UTL_FILE.fopen('DATA_PUMP_DIR','{0}','wb',32766); UTL_FILE.fclose(fi); END;"
          con = cx_Oracle.connect('User/[email protected]')
          cur = con.cursor()
          cur.execute(UTL_FILE_NEW_FILE.format(file_name))
          chunk = 32760
          f = open(src_name, 'rb')
          line = f.read(chunk)
          cur.callfunc('gen_dmp', cx_Oracle.STRING, (file_name, line))
          while (len(line)) > 0:
              line = f.read(chunk)
              cur.callfunc('gen_dmp', cx_Oracle.STRING, (file_name, line))
          cur.close()
          con.close()

       

      参考链接:

      http://www.1click-soft.com/tfgjylgw/questions/23486198/how-to-import-oracle-dump-from-ec2-instance-to-rds-in-aws

      http://www.1click-soft.com/tfgjylgw/quentinhardy/odat/blob/master/UtlFile.py

      www.1click-soft.comtruehttp://www.1click-soft.com/oracle/1311218.htmlTechArticle通过Python脚本将DMP文件写入AWS RDS oracle中,pythonaws 由于RDS(oracle)不直接支持SSH,FTP(基于安全因素吧).所以原有系统expdp或exp出来的dmp文件,不...

      相关文章

        暂无相关文章
      相关搜索:

      帮客评论

      视觉看点
      百度 360 搜狗