Rails环境下持久化Tempfile并上传至S3桶的技术方案咨询

核心问题原因 #

Active Job是异步执行的，和创建Tempfile的进程属于不同进程（甚至不同服务器），而Ruby原生Tempfile默认绑定创建进程，进程结束后会自动清理文件；即使手动写到/tmp，也可能被系统自动清理机制或Ruby的回收逻辑删除，导致异步进程无法访问。

方案1：手动创建持久化临时文件（最直接可控） #

绕过Ruby的Tempfile自动回收机制，手动在tmp目录生成唯一文件名，上传完成后手动清理：

# 步骤1：创建持久化临时文件
unique_filename = "#{SecureRandom.uuid}_temp_file.txt"
file_path = Rails.root.join('tmp', unique_filename).to_s

File.open(file_path, 'w') do |f|
  f.write('你的内容')
end

# 步骤2：传递文件路径给Active Job
S3UploadJob.perform_later(file_path)

# Active Job实现
class S3UploadJob < ApplicationJob
  queue_as :default

  def perform(file_path)
    S3UploadService.call(file_path)
  end
end

# 服务文件：上传后清理文件
class S3UploadService
  def self.call(file_path)
    # 执行S3上传逻辑（示例用AWS SDK）
    Aws::S3::Client.new.put_object(
      bucket: '你的存储桶名称',
      key: "uploaded_files/#{File.basename(file_path)}",
      body: File.open(file_path)
    )

    # 上传完成后手动删除临时文件
    File.delete(file_path) if File.exist?(file_path)
  end
end

方案2：用ActiveStorage Blob存储内容（Rails原生方案） #

无需管理文件路径，直接将内容存入ActiveStorage临时Blob，异步进程通过Blob Key读取内容：

# 步骤1：创建临时Blob存储内容
content = '你的内容'
temp_blob = ActiveStorage::Blob.create_and_upload!(
  io: StringIO.new(content),
  filename: 'temp_upload.txt',
  content_type: 'text/plain' # 根据文件类型调整
)

# 步骤2：传递Blob Key给Active Job
S3UploadJob.perform_later(temp_blob.key)

# Active Job实现
class S3UploadJob < ApplicationJob
  queue_as :default

  def perform(blob_key)
    blob = ActiveStorage::Blob.find_by(key: blob_key)
    S3UploadService.call(blob)
  end
end

# 服务文件：从Blob读取并上传
class S3UploadService
  def self.call(blob)
    blob.open do |file|
      Aws::S3::Client.new.put_object(
        bucket: '你的存储桶名称',
        key: "uploaded_files/#{blob.filename}",
        body: file
      )
    end

    # 异步清理临时Blob
    blob.purge_later
  end
end

方案3：配置Tempfile禁用自动清理（仍用Tempfile类） #

如果坚持使用Tempfile，需显式关闭自动删除，并确保文件被关闭后再传递路径：

# 步骤1：创建不自动删除的Tempfile
temp_file = Tempfile.create(
  ['temp_prefix', '.txt'], # 前缀和后缀
  Rails.root.join('tmp'),  # 指定存储目录
  delete: false            # 禁用自动删除
)
temp_file.write('你的内容')
temp_file.close # 必须关闭，否则其他进程可能无法读取

file_path = temp_file.path

# 步骤2：传递路径给Job，后续上传逻辑同方案1
S3UploadJob.perform_later(file_path)

关键注意事项 #

• 多服务器部署时，不要用本地tmp目录，需用共享存储（如NFS）或方案2的ActiveStorage（配置成跨服务器可用的存储后端）。
• 数据库存储方案：直接存内容的字符串/二进制数据，不要存文件路径——路径仅在创建进程的服务器有效，异步进程或其他服务器无法访问。
• 无论哪种方案，都要手动清理临时文件/Blob，避免磁盘或存储资源堆积。

内容的提问来源于stack exchange，提问作者Derial_31