亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

python 從遠程批量下載文件到本地

系統 3047 0

需求:

1、從postgresql數據庫中查出附件名稱

2、從遠程服務器下載對應的附件

用到的python模塊paramiko、psycopg2。

paramiko是用python寫的一個模塊,遵循SSH2協議,支持以加密和認證的方式,進行遠程服務器的連接。利用該模塊,可以方便的進行ssh連接和sftp協議進行sftp文件傳輸以及遠程命令執行。
psycopg2是python的postgresql數據庫接口,可以對數據庫進行操作。

            conndb.py文件代碼功能是連接數據庫,查詢附件的名稱,用于拼接地址。
          
            
              import psycopg2

def conn_db():
    # database,user,password,host,port分別對應要連接的PostgreSQL數據庫的數據庫名、數據庫用戶名、用戶密碼、主機、端口信息
    conn = psycopg2.connect(database="h", user="oe", password="1234", host="10.18.xxx.xxx", port="5432")
    cursor = conn.cursor()
    # 執行查詢命令
    cursor.execute("select store_fname,datas_fname from contract_attachment where contract_interview_id in(select id from hr_re)")

    result = cursor.fetchall()
    print(result)
    # cursor.close()   #關閉游標
    conn.close()     #關閉連接
    return result
            
          
            download.py進行連接服務器和下載文件的操作
          
            
              from conndb import conn_db
import os
import re
import logging
import paramiko
import base64

_logger = logging.getLogger(__name__)
PATH = '/hr/openerp8/openerp/'
LOCATION='file:///filestore'
dbname='h'

def full_path(path):
    # location = 'file:filestore'
    assert LOCATION.startswith('file:'), "Unhandled filestore location %s" % LOCATION
    location = LOCATION[5:]

    # sanitize location name and path
    location = re.sub('[.]', '', location)
    location = location.strip('/\\')

    path = re.sub('[.]', '', path)
    path = path.strip('/\\')
    res_path =os.path.join(PATH, location, dbname, path)
    return  res_path.replace('\\','/')


def data_get(data):
    result = []

    bin_size = False
    for attach in data:
        # f_path = None
        if LOCATION and attach[0]:
            f_path = full_path(attach[0])
            result.append(f_path)
            # os.remove(f_path)

    return result



def RemoteScp(host_ip, host_port, host_username, host_password, remote_file, local_file):
    scp = paramiko.Transport((host_ip, host_port))
    scp.connect(username=host_username, password=host_password)
    sftp = paramiko.SFTPClient.from_transport(scp)
    for file in remote_file:
        file_path,filename =os.path.split(file)
        sftp.get(file, local_file+'/'+filename)
    scp.close()
    return ("success")

if __name__ == '__main__':
    ip="10.18.xxx.xxx"
    user="root"
    passwd="1234"
    host_port = 22

    data = conn_db() #取文件名集合
    all_file = data_get(data)
    local_path = 'F:/ProjectTrain/download_file/att'

    RemoteScp(ip, host_port, user, passwd, all_file, local_path)


            
          

?


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 免费观看黄a一级视频日本 免费观看黄色 | 中文字幕在线看视频一区二区三区 | 看一级特黄a大片日本片黑人 | 天天做天天爱夜夜想毛片 | 精品在线99 | 午夜在线网站 | 亚洲一区二区三区免费看 | 亚洲一二三 | 一级毛片免费视频日本 | 欧美日韩国产高清精卡 | 日韩一级精品视频在线观看 | 亚洲国产精品久久久天堂 | 中文字幕在线激情日韩一区 | 在线播放真实国产乱子伦 | 久久久久久人精品免费费看 | 久久久穴 | 综合亚洲色图 | 中文字幕日韩一区二区不卡 | 天天操操操操操 | 国产精品视频网 | 日韩欧美视频一区二区在线观看 | 中文字幕视频在线免费观看 | 日本老太做爰xx | 婷婷99精品国产97久久综合 | 久久美女精品国产精品亚洲 | 国产精品夜色一区二区三区 | 亚洲国产欧美日韩 | 国产成人亚洲欧美激情 | 久久精品国产2020观看福利色 | 性短视频在线观看免费不卡流畅 | 国产探花视频在线观看 | 日韩毛片免费 | 久久久这里有精品 | 97se色综合一区二区二区 | 欧美成人精品欧美一级乱黄 | 欧美一级视频在线观看 | 97色伦影院 | 老司机午夜性大片 | 四虎影院永久网站 | 蜜桃精品免费久久久久影院 | 在线看的成人性视频 |