Komprimierung

Das Modul compress kodiert und dekodiert Strings mit gzip, Brotli, Zstandard, rohem DEFLATE und zlib.

Diese Seite ist eine API-Referenz mit partiellen HTTP- und Storage-Rezepten. Jede Operation materialisiert ihre vollständige Ein- und Ausgabe als Lua-Strings; verwenden Sie Archive- oder Stream-APIs, wenn Daten im Streaming verbleiben müssen. Die Beispiele setzen voraus, dass der Eintrag compress und alle separat benötigten Module wie json oder http aktiviert.

Laden

local compress = require("compress")

Fügen Sie compress zur modules:-Liste des ausführbaren Eintrags hinzu, bevor Sie das Modul laden.

GZIP

Gzip ist in RFC 1952 definiert.

Komprimieren {id="gzip-compress"}

-- Compress for HTTP response
local body, json_err = json.encode(large_response)
if json_err then return nil, json_err end
local compressed, err = compress.gzip.encode(body)
if err then
    return nil, err
end

-- Set Content-Encoding header
local header_err = res:set_header("Content-Encoding", "gzip")
if header_err then return nil, header_err end
local write_err = res:write(compressed)
if write_err then return nil, write_err end

-- Maximum compression for storage
local archived, archive_err = compress.gzip.encode(data, {level = 9})
if archive_err then return nil, archive_err end

-- Fast compression for real-time
local fast, fast_err = compress.gzip.encode(data, {level = 1})
if fast_err then return nil, fast_err end

Optionen {id="gzip-compress-options"}

Gibt zurück: string, error

Dekomprimieren {id="gzip-decompress"}

-- Decompress HTTP request
local content_encoding, header_err = req:header("Content-Encoding")
if header_err then return nil, header_err end
if content_encoding == "gzip" then
    local body, body_err = req:body()
    if body_err then return nil, body_err end
    local decompressed, err = compress.gzip.decode(body)
    if err then
        return nil, errors.new("Invalid gzip data"):kind(errors.INVALID)
    end
    body = decompressed
end

-- Decompress with size limit (prevent zip bombs)
local decompressed, err = compress.gzip.decode(data, {max_size = 10 * 1024 * 1024})
if err then
    return nil, errors.new("Decompressed size exceeds 10MB limit"):kind(errors.INVALID)
end

Optionen {id="gzip-decompress-options"}

Gibt zurück: string, error

Brotli

Brotli ist in RFC 7932 definiert und wird häufig für komprimierte Textinhalte verwendet.

Komprimieren {id="brotli-compress"}

-- Best for static assets and text content
local compressed, err = compress.brotli.encode(html_content, {level = 11})
if err then return nil, err end

-- Store `compressed` through the application's cache contract if needed.

-- Moderate compression for API responses
local compressed, err = compress.brotli.encode(json_data, {level = 4})
if err then return nil, err end

Optionen {id="brotli-compress-options"}

Gibt zurück: string, error

Dekomprimieren {id="brotli-decompress"}

local decompressed, err = compress.brotli.decode(compressed_data)
if err then
    return nil, err
end

-- With size limit
local decompressed, err = compress.brotli.decode(data, {max_size = 50 * 1024 * 1024})
if err then return nil, err end

Optionen {id="brotli-decompress-options"}

Gibt zurück: string, error

Zstandard

Zstandard ist ein universelles Komprimierungsformat nach RFC 8878.

Komprimieren {id="zstd-compress"}

-- Good balance of speed and ratio
local compressed, err = compress.zstd.encode(binary_data)
if err then return nil, err end

-- Higher compression for archival
local archived, archive_err = compress.zstd.encode(data, {level = 19})
if archive_err then return nil, archive_err end

-- Fast mode for latency-sensitive payloads
local fast, fast_err = compress.zstd.encode(data, {level = 1})
if fast_err then return nil, fast_err end

Optionen {id="zstd-compress-options"}

Gibt zurück: string, error

Dekomprimieren {id="zstd-decompress"}

local decompressed, err = compress.zstd.decode(compressed_data)
if err then
    return nil, err
end

Optionen {id="zstd-decompress-options"}

Gibt zurück: string, error

Dictionaries {id="zstd-dictionaries"}

Trainieren Sie ein Dictionary aus ähnlichen Beispiel-Payloads und übergeben Sie es anschließend über die Option dict an encode und decode. Zum Dekodieren ist dasselbe Dictionary erforderlich, das beim Kodieren verwendet wurde.

local dict, err = compress.zstd.train_dict(samples, { size = 112640 })
if err then return nil, err end
local packed, pack_err = compress.zstd.encode(data, { dict = dict })
if pack_err then return nil, pack_err end
local original, decode_err = compress.zstd.decode(packed, { dict = dict })
if decode_err then return nil, decode_err end

train_dict(samples, options?)

Gibt zurück: string, error (die Dictionary-Bytes)

inspect_dict(dict)

Gibt zurück: table, error — {id: integer, content_size: integer}

Deflate

Rohes DEFLATE ist in RFC 1951 definiert und wird auch innerhalb anderer Formate verwendet.

Komprimieren {id="deflate-compress"}

local compressed, err = compress.deflate.encode(data, {level = 6})
if err then return nil, err end

Optionen {id="deflate-compress-options"}

Gibt zurück: string, error

Dekomprimieren {id="deflate-decompress"}

local decompressed, err = compress.deflate.decode(compressed)
if err then return nil, err end

Optionen {id="deflate-decompress-options"}

Gibt zurück: string, error

Zlib

Zlib umschließt DEFLATE-Daten gemäß RFC 1950 mit Header und Prüfsumme.

Komprimieren {id="zlib-compress"}

local compressed, err = compress.zlib.encode(data, {level = 6})
if err then return nil, err end

Optionen {id="zlib-compress-options"}

Gibt zurück: string, error

Dekomprimieren {id="zlib-decompress"}

local decompressed, err = compress.zlib.decode(compressed)
if err then return nil, err end

Optionen {id="zlib-decompress-options"}

Gibt zurück: string, error

Algorithmus auswählen

-- HTTP response based on Accept-Encoding
local accept, header_err = req:header("Accept-Encoding")
if header_err then return nil, header_err end
accept = accept or ""
local body, json_err = json.encode(response_data)
if json_err then return nil, json_err end

local qualities = {}
for item in accept:gmatch("[^,]+") do
    local coding = item:match("^%s*([^;%s]+)")
    local has_q = item:match(";%s*[qQ]%s*=") ~= nil
    local q_text = item:match(";%s*[qQ]%s*=%s*([^;%s,]+)")
    local q
    if not has_q then
        q = 1
    elseif q_text == "0" or q_text == "1" or
           (q_text and q_text:match("^0%.%d?%d?%d?$")) or
           (q_text and q_text:match("^1%.0?0?0?$")) then
        q = tonumber(q_text)
    end
    if coding and q and q >= 0 and q <= 1 then
        coding = coding:lower()
        qualities[coding] = math.max(qualities[coding] or 0, q)
    end
end

local function quality(coding)
    if qualities[coding] ~= nil then return qualities[coding] end
    if coding == "identity" then
        return qualities["*"] == 0 and 0 or 1
    end
    return qualities["*"] or 0
end

local selected, selected_q = nil, -1
for _, coding in ipairs({"br", "gzip", "identity"}) do
    local q = quality(coding)
    if q > selected_q then
        selected, selected_q = coding, q
    end
end

-- Include every field used by this handler or its surrounding middleware.
local vary_fields = {"Accept-Encoding"}
local vary_err = res:set_header("Vary", table.concat(vary_fields, ", "))
if vary_err then return nil, vary_err end

if selected_q <= 0 then
    local status_err = res:set_status(http.STATUS.NOT_ACCEPTABLE)
    if status_err then return nil, status_err end
    local write_err = res:write("No acceptable content encoding")
    if write_err then return nil, write_err end
elseif selected == "br" then
    local compressed, compress_err = compress.brotli.encode(body)
    if compress_err then return nil, compress_err end
    local set_err = res:set_header("Content-Encoding", "br")
    if set_err then return nil, set_err end
    local write_err = res:write(compressed)
    if write_err then return nil, write_err end
elseif selected == "gzip" then
    local compressed, compress_err = compress.gzip.encode(body)
    if compress_err then return nil, compress_err end
    local set_err = res:set_header("Content-Encoding", "gzip")
    if set_err then return nil, set_err end
    local write_err = res:write(compressed)
    if write_err then return nil, write_err end
else
    local write_err = res:write(body)
    if write_err then return nil, write_err end
end

Dieser partielle Handler parst exakte Coding-Tokens und RFC-q-Werte, berücksichtigt explizite Ablehnungen wie br;q=0 und setzt Vary: Accept-Encoding. set_header ersetzt einen vorhandenen Vary-Wert; fügen Sie daher jedes weitere Feld, das umgebende Middleware verwendet, zu vary_fields hinzu, bevor Sie den Header setzen. Ein vollständiger HTTP-Stack kann stattdessen einen gemeinsamen Negotiation-Helper bereitstellen.

Fehler

Siehe Fehlerbehandlung für die Arbeit mit Fehlern.