Rails6でフォームから画像が入ったzipを受け取って、画像処理して、S3へアップロードする

<%= form_with url: image_convert_upload_path do |form| %>
  <%= form.file_field :image_file %>
  <%= form.text_field :s3_path %>
  <%= form.submit "アップロード", data: { disable_with: '処理中...' },accept: ".zip", class: "" %>
<% end %>

require 'zip'
require 'fileutils'
require 'aws-sdk-s3'

def upload_form
  
end

def image_convert_upload
　#pathを設定しておく
  zip_path = params[:image_file].path
  tmp_path = "#{Rails.root}/tmp/#{Time.zone.now.strftime('%Y%m%d%H%M%S')}/"
  s3_path = params[:s3_path]
  
  Zip::File.open(zip_path) do |zip|
      
      zip.each do |entry|
      ext = File.extname(entry.name)
      next if ext.blank? || File.basename(entry.name).count(".") > 1
      
      # zipファイルの中に階層がある場合、ディレクトリを作成する
      dir_name = File.dirname(entry.name)
      dir_path = tmp_path + dir_name
      FileUtils.mkdir_p(dir_path)
      
      # テンポラリファイルを作成
      Tempfile.open([File.basename(entry.to_s), ext]) do |file|
        begin
          # 一時ファイルを作成
          entry.extract(file.path) { true }
          
          image = Magick::ImageList.new(file.path).first
          width = image.columns
          height = image.rows
          new_image = image.roll(width*3/4, height*3/4)
          new_image.write(tmp_path + entry.name)
          
          new_image_file = File.new(tmp_path + entry.name) 
          
          bucket_name = 'バケット名'
          object_key = s3_path + entry.name
          data = new_image_file.read
          region = 'リージョン'
          s3_client = Aws::S3::Client.new(region: region)
        
          if object_uploaded?(s3_client, bucket_name, object_key, data)
            puts "Object '#{object_key}' uploaded to bucket '#{bucket_name}'."
          else
            puts "Object '#{object_key}' not uploaded to bucket '#{bucket_name}'."
          end
        ensure
          # 終わったらclose
          file.close!
        end
      end
    end

    # tmpディレクトリに作成したディレクトリを丸ごと削除
    FileUtils.rm_r(tmp_path)
  end
 
  redirect_to upload_form_path
end


def object_uploaded?(s3_client, bucket_name, object_key, data)
  response = s3_client.put_object(
    bucket: bucket_name,
    key: object_key,
    body: data,
    acl: 'public-read'
  )
  if response.etag
    return true
  else
    return false
  end
rescue StandardError => e
  puts "Error uploading object: #{e.message}"
  return false
end

gem 'rmagick'
gem 'aws-sdk-s3'
gem 'rubyzip' 

<%= form_with url: image_convert_upload_path do |form| %>

　#ファイル受け取る
  <%= form.file_field :image_file %>
　#S3へアップロードする際にpathを追加したい場合のため、任意項目です
  <%= form.text_field :s3_path %>　

　#data: { disable_with: '処理中...' }とすることで、アップロード中に再度クリックできないようにしています。
　#accept: ".zip"とすることで、zipのみ受け取るように指定しています。不要であれば外してください。
  <%= form.submit "アップロード", data: { disable_with: '処理中...' },accept: ".zip", class: "" %>
<% end %>

def image_convert_upload
　#pathを設定しておく
　#Viewのフォームから受け取った:image_fileのパスです。
  zip_path = params[:image_file].path
　#tmpディレクトリへ一時的にデータを保存するためのパスです。作成するディレクトリ名は、他と重複しないように日付時間とします。
  tmp_path = "#{Rails.root}/tmp/#{Time.zone.now.strftime('%Y%m%d%H%M%S')}/"
　#Viewのフォームから受け取った:s3_pathのパスです。paramsで受け取ります。
  s3_path = params[:s3_path]

  # 〜省略〜
end

def image_convert_upload
　# 〜省略〜  
  Zip::File.open(zip_path) do |zip|
      
　　　＃zip内にあるファイルを一つずつ取り出す処理を開始します。
      zip.each do |entry|
　　　
　　　＃ファイルの拡張子をextに代入
      ext = File.extname(entry.name)
　　　＃ゴミデータを省くための処理です。拡張子がない、もしくはファイル名に.が1個よりも多い場合はスキップさせます。
      next if ext.blank? || File.basename(entry.name).count(".") > 1
      
      # 取り出したファイルの階層を把握します。
      dir_name = File.dirname(entry.name)
      # ディレクトリを事前に作っておく必要があるため、tempディレクトリへzipファイル内の階層と同じディレクトリを作成します。
      dir_path = tmp_path + dir_name
      FileUtils.mkdir_p(dir_path)
      
      # 〜省略〜
      end
    # tmpディレクトリに作成したディレクトリを丸ごと削除
    FileUtils.rm_r(tmp_path)
  end
 
  redirect_to upload_form_path
end

  Zip::File.open(zip_path) do |zip|  
    zip.each do |entry|
      puts entry.name
    end
  end

entryname = "aaa/bbb/ccc/abc.jpg"

puts File.extname(entryname)
=> .jpg
puts File.basename(entryname)
=> abc.jpg
puts File.dirname(entryname)
=> aaa/bbb/ccc

def image_convert_upload
　# 〜省略〜  
  Zip::File.open(zip_path) do |zip|
      
      # 〜省略〜

      # テンポラリファイルを作成
      Tempfile.open([File.basename(entry.to_s), ext]) do |file|
        begin
          # 一時ファイルを作成
          entry.extract(file.path) { true }
          
          #rmagickで画像処理するために画像ファイルを読み込みます
          image = Magick::ImageList.new(file.path).first
          #画像の横幅を取得したり
          width = image.columns
          #画像の縦幅を取得したりできます。
          height = image.rows
          #画像の左上を切り取る場合だと下記で処理できます。
          new_image = img.crop(0, 0, width/2, height/2)

          #画像処理が終わったら、tempディレクトリへ作成したディレクトリへ書き出します。
          new_image.write(tmp_path + entry.name)
          
          #書き出した画像データをnew_image_fileとして扱えるようにします。
          new_image_file = File.new(tmp_path + entry.name) 
          
          # 〜省略〜
        ensure
          # 終わったらclose
          file.close!
        end
      end
    end
　　# 〜省略〜
  end
  # 〜省略〜
end

def object_uploaded?(s3_client, bucket_name, object_key, data)
 　# 〜省略〜
end

def image_convert_upload
　# 〜省略〜
  Zip::File.open(zip_path) do |zip|
      
      zip.each do |entry|
      # 〜省略〜

      # テンポラリファイルを作成
      Tempfile.open([File.basename(entry.to_s), ext]) do |file|
        begin

          # 〜省略〜
          
          new_image_file = File.new(tmp_path + entry.name) 
          
          bucket_name = 'バケット名'
          object_key = s3_path + entry.name
          data = new_image_file.read
          region = 'リージョン'
          s3_client = Aws::S3::Client.new(region: region)
        
          if object_uploaded?(s3_client, bucket_name, object_key, data)
            puts "Object '#{object_key}' uploaded to bucket '#{bucket_name}'."
          else
            puts "Object '#{object_key}' not uploaded to bucket '#{bucket_name}'."
          end
        ensure
          # 終わったらclose
          file.close!
        end
      end
    end
    # tmpディレクトリに作成したディレクトリを丸ごと削除
    FileUtils.rm_r(tmp_path)
  end
  # 〜省略〜
end


def object_uploaded?(s3_client, bucket_name, object_key, data)
  response = s3_client.put_object(
    bucket: bucket_name,
    key: object_key,
    body: data,
    acl: 'public-read'
  )
  if response.etag
    return true
  else
    return false
  end
rescue StandardError => e
  puts "Error uploading object: #{e.message}"
  return false
end