Hôm nay mình xin chia sẻ kinh nghiệm cách download file csv từ 1 FTP, SFTP server về local của mình và đọc file csv đó,sau đó sẽ hiển thị ra dữ liệu.
Hiện tại trên FTP, SFTP server mình đã uploaded sẵn 1 file csv có tên là SampleCSV.csv,
bên dưới đây là các bước kết nối đến FTP,SFTP server, download về local, hiển thị dữ liệu.
1. Thực hiện kết nối đến FTP server
// 1. Kết nối và login to FTP server
$ftp_server = "Your host name";
$ftp_conn = ftp_connect($ftp_server) or die("Could not connect to $ftp_server");
$login = ftp_login($ftp_conn, 'Your user name', 'Your password');
ftp_pasv($ftp_conn, TRUE);
// 2.Khái báo 2 biến như bên dưới
$local_file = $_SERVER['DOCUMENT_ROOT']."/SampleCSV.csv"; // Đường dẫn dến file csv trên local của mình(Ban đầu chưa có file nhé)
$server_file = "SampleCSV.csv";//tên file csv trên FPT server
// 3.Cấp quyền cho file csv
if (file_exists($local_file)) {
chmod($local_file, 0777);
}
// 4. Thực hiện download file về local
if (ftp_get($ftp_conn, $local_file, $server_file, FTP_ASCII)) {
if (file_exists($local_file)) {
if (($handle = fopen($local_file, "r")) !== FALSE) {
while (($data = fgetcsv($handle, 99999, ",")) !== FALSE) {
echo "<pre>";
print_r($data); // hiển thị dữ liệu tương ứng với mỗi row trong file csv
echo "</pre>";
}
fclose($handle);
}
} else {
echo "File không tồn tại dưới local";
}
} else {
echo "Xẩy ra lỗi trong quá trình download file về local";
}
2. Thực hiện kết nối đến SFTP server bằng libssh2 library
Do mình sẽ dùng libssh2 library để kết nối đến SFTP server, hiện tại trên server local của mình(xampp) chưa cài đặt libssh2 library,
do đó mình sẽ thực hiện download và cài đặt trên server local của mình trước nhé.
Link download: https://pecl.php.net/package/ssh2
Version mới nhất ở thời điểm mình làm ví dụ là 1.3.1 như ảnh bên dưới và click vào icon windows màu xanh có chứ DLL.
Màn hình tiếp theo mình sẽ chọn bản phù hợp với phiên bản php hiện tại mình đang dùng là php 7.4
Giải nén file vừa download về và copy 2 files php_ssh2.dll, php_ssh2.pdb trong folder giải nén vào thư mục xampp\php\ext trên server local như ảnh bên dưới.
Bước tiếp theo để sử dụng được thư viện này chúng ta phải vào file php.ini để thêm dòng ở ô màu đỏ bên dưới để enable thư viện đó nhé.
Bây giờ mình sẽ khơi động lại xampp để viết code sử dụng thư viện libssh2 nhé!
Source code:
$connection = ssh2_connect('Your host name');
// Kiểm tra login
if (!ssh2_auth_password($connection, 'Your user name', 'Your password')) {
throw new Exception('Unable to connect.');
} else {
echo "connected";
}
// Tạo kết nối đến SFTP server
if (!$sftp = ssh2_sftp($connection)) {
throw new Exception('Unable to create SFTP connection.');
} else {
echo "connected2";
}
//Biến chứa danh sách các files sẽ lấy từ SFTP server
$files = array();
//Đường dẫn thư mục chứa file csv trên SFTP server
$dirHandle = opendir("ssh2.sftp://$sftp/csv/");
// Tìm các files trong thư mục, bỏ qua các files có đuôi kiểu (. & ..)
while (false !== ($file = readdir($dirHandle))) {
if ($file != '.' && $file != '..') {
$files[] = $file;
}
}
// Đường dẫn dến file csv trên local của mình(Ban đầu chưa có file nhé)
$local_file = $_SERVER['DOCUMENT_ROOT']."/localDirectory/SampleCSV.csv";
if (count($files)) {
foreach ($files as $fileName) {
if ($fileName == "SampleCSV.csv") {
// Remote stream
if (!$remoteStream = @fopen("ssh2.sftp://$sftp/csv/$fileName", 'r')) {
throw new Exception("Unable to open remote file: $fileName");
}
// Local stream
if (!$localStream = @fopen($_SERVER['DOCUMENT_ROOT']."/localDirectory/$fileName", 'w')) {
throw new Exception("Unable to open local file for writing: /localDirectory/$fileName");
}
// Write from our remote stream to our local stream
$read = 0;
$fileSize = filesize("ssh2.sftp://$sftp/csv/$fileName");
while ($read < $fileSize && ($buffer = fread($remoteStream, $fileSize - $read))) {
// Increase our bytes read
$read += strlen($buffer);
// Write to our local file
if (fwrite($localStream, $buffer) === FALSE) {
throw new Exception("Unable to write to local file: /localDirectory/$fileName");
} else {
if (file_exists($local_file)) {
if (($handle = fopen($local_file, "r")) !== FALSE) {
while (($branch = fgetcsv($handle, 99999, ",")) !== FALSE) {
echo "<pre>";
print_r($branch);
echo "</pre>";
}
}
}
}
}
// Close our streams
fclose($localStream);
fclose($remoteStream);
}
}
}
Như vậy là mình đã hoàn thành một ví dụ đơn giản về cách kết nối, download, đọc file csv từ FTP, SFTP server khác,
do kiến thức của mình có hạn,nếu có gì thiếu sót và thắc mắc mọi người hay comment cho mình nhé!