<\/span><\/h2>\n\n\n\n\u5982\u4e0b\u4ee3\u7801\u653e\u5728gclusterdb\u4e0b\uff0c\u53ef\u4ee5\u6839\u636e\u5177\u4f53\u60c5\u51b5\u4fee\u6539\u3002<\/p>\n\n\n\n
\u4f20\u5165\u53c2\u6570\u4e3a\u4e3b\u673a\uff0c\u7528\u6237\u540d\uff0c\u5bc6\u7801\uff0c\u6e90\u540d\u5b57\u548c\u76ee\u6807\u540d\u5b57\u3002<\/p>\n\n\n\n
\u672c\u6837\u4f8b\u672a\u5b9e\u73b0\u7aef\u53e3\u7684\u4fee\u6539\uff0c\u5982\u4e0d\u662f\u9ed8\u8ba4\u7684ftp\u7aef\u53e3\uff0c\u53ef\u4ee5\u81ea\u884c\u5b8c\u5584\u4ee3\u7801\u3002<\/p>\n\n\n\n
use gclusterdb;\ndrop function if exists ftpRename;\ncreate function ftpRename(server varchar(100),username varchar(100),password varchar(100),sourceFilename varchar(1000),targetFilename varchar(1000))\nreturns varchar\n$$\nfrom ftplib import FTP\nftp = FTP(server)\nftp.login(username, password)\nftp.rename(sourceFilename,targetFilename)\nftp.close()\nreturn 'OK'\n\n$$ language plpythonu;<\/code><\/pre>\n\n\n\n\u8c03\u7528\u65b9\u6cd5<\/p>\n\n\n\n
\ngbase> select ftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1.csv.tmp','\/home\/gbase\/t1.csv');\n+------------------------------------------------------------------------------------------------+\n| ftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1..scv.tmp','\/home\/gbase\/t1.csv') |\n+------------------------------------------------------------------------------------------------+\n| OK |\n+------------------------------------------------------------------------------------------------+\n1 row in set (Elapsed: 00:00:00.08)\n<\/code><\/pre>\n\n\n\n<\/span>python udf\u5b9e\u73b0 SFTP\u6539\u540d\u4ee3\u7801<\/span><\/h2>\n\n\n\n\u9ed8\u8ba4\u7684python\u5e93\u4e0d\u652f\u6301sftp, \u672c\u4f8b\u7528\u4e86pysftp\u5e93\u3002 \u53ef\u4ee5\u901a\u8fc7pip install pysftp\u5b89\u88c5\u3002<\/p>\n\n\n\n
\u5176\u5b83\u4ecb\u7ecd\u4e0eFTP\u4e00\u6837\u3002<\/p>\n\n\n\n
use gclusterdb;\ndrop function if exists sftpRename;\ncreate function sftpRename(server varchar(100),v_username varchar(100),v_password varchar(100),sourceFilename varchar(1000),targetFilename varchar(1000))\nreturns varchar\n$$\nimport pysftp\nwith pysftp.Connection(server, username=v_username, password=v_password) as sftp:\n sftp.rename(sourceFilename,targetFilename)\n sftp.close()\nreturn 'OK'\n\n$$ language plpythonu;\n<\/code><\/pre>\n\n\n\n\u4f7f\u7528\u6837\u4f8b<\/p>\n\n\n\n
gbase> select sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1.csv.tmp','\/home\/gbase\/t1.csv');\n+------------------------------------------------------------------------------------------------+\n| sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1..scv.tmp','\/home\/gbase\/t1.csv') |\n+------------------------------------------------------------------------------------------------+\n| OK |\n+------------------------------------------------------------------------------------------------+\n1 row in set (Elapsed: 00:00:00.08)<\/code><\/pre>\n\n\n\n<\/span>Summary<\/span><\/h2>\n\n\n\n\u4e3a\u4e86\u907f\u514d\u5bfc\u51fa\u6587\u4ef6\u8fc7\u7a0b\u4e2d\u88ab\u610f\u5916\u4f7f\u7528\uff0c\u53ef\u4ee5\u7528\u5982\u4e0b2\u4e2a\u6b65\u9aa4\u7684\u65b9\u6848\u6765\u505a<\/p>\n\n\n\n
gbase> select * from t1 into outfile 'sftp:\/\/gbase:gbase1234@10.0.2.201\/home\/gbase\/t1.csv.tmp' fields terminated by ',';\nQuery OK, 3 rows affected (Elapsed: 00:00:00.32)\n\ngbase> select gclusterdb.sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1.csv.tmp','\/home\/gbase\/tmp\/t1.csv');\n+-----------------------------------------------------------------------------------------------------------+\n| gclusterdb.sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/t1.csv.tmp','\/home\/gbase\/tmp\/t1.csv') |\n+-----------------------------------------------------------------------------------------------------------+\n| OK |\n+-----------------------------------------------------------------------------------------------------------+\n1 row in set (Elapsed: 00:00:00.43)<\/code><\/pre>\n\n\n\n\u5176\u4e2d\u7684\u4e34\u65f6\u6587\u4ef6\uff0c\u53ef\u4ee5\u8de8\u76ee\u5f55\u3002\u524d\u63d0\u662f\u6709\u5199\u5165\u6743\u9650\u3002 \u5982\u4e0b\u4f8b\u5b50\u4f7f\u7528\u4e86\u4e34\u65f6\u76ee\u5f55tmp \u5e76\u4e14\u540d\u5b57\u4e5f\u5e26\u4e86tmp\u540e\u7f00\u3002<\/p>\n\n\n\n
gbase> select * from t1 into outfile 'sftp:\/\/gbase:gbase1234@10.0.2.201\/home\/gbase\/tmp<\/span>\/t1_2.csv.tmp<\/span>' fields terminated by ',';\nQuery OK, 3 rows affected (Elapsed: 00:00:00.44)\n\ngbase> select gclusterdb.sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/tmp\/t1_2.csv.tmp','\/home\/gbase\/t1_2.csv');\n+---------------------------------------------------------------------------------------------------------------+\n| gclusterdb.sftprename('10.0.2.201','gbase','gbase1234','\/home\/gbase\/tmp\/t1_2.csv.tmp','\/home\/gbase\/t1_2.csv') |\n+---------------------------------------------------------------------------------------------------------------+\n| OK |\n+---------------------------------------------------------------------------------------------------------------+\n1 row in set (Elapsed: 00:00:00.44)\n<\/code><\/pre>","protected":false},"excerpt":{"rendered":"GBase 8a\u7684\u5bfc\u51fa\u529f\u80fd\u652f\u6301ftp,sftp\u7b49\u534f\u8bae\u3002\u5982\u679c\u5bfc\u51fa\u5185\u5bb9\u8f83\u591a\uff0c\u5219\u76ee\u6807\u6587\u4ef6\u9700\u8981\u4e00\u6bb5\u65f6\u95f4\u624d\u80fd\u751f\u6210\u3002\u800c\u5728\u5bfc\u51fa\u671f\u95f4\u5982\u679c\u8be5\u6587\u4ef6\u88ab\u4f7f\u7528\uff0c\u5219\u5176\u5185\u5bb9\u5904\u4e8e\u4e0d\u5b8c\u6574\u72b6\u6001\uff0c\u4f1a\u9020\u6210\u6570\u636e\u4e0d\u4e00\u81f4\uff0c\u683c\u5f0f\u62a5\u9519\u7b49\u60c5\u51b5\u3002\u672c\u6587\u901a\u8fc7python\u5b9e\u73b0ftp\u548csftp\u7684\u6539\u540d\u529f\u80fd\uff0c\u5728\u4e00\u5b9a\u89c4\u5219\u4e0b\u89c4\u907f\u8fd9\u4e2a\u60c5\u51b5\u3002<\/p>","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3],"tags":[98,22,91],"class_list":["post-12782","post","type-post","status-publish","format-standard","hentry","category-gbase8a","tag-python","tag-22","tag-udf"],"_links":{"self":[{"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/posts\/12782","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/comments?post=12782"}],"version-history":[{"count":11,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/posts\/12782\/revisions"}],"predecessor-version":[{"id":12797,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/posts\/12782\/revisions\/12797"}],"wp:attachment":[{"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/media?parent=12782"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/categories?post=12782"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gbase8.cn\/en\/wp-json\/wp\/v2\/tags?post=12782"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}