Amazon Redshift non supporterà più la creazione di nuovi Python a UDFs partire dal 1° novembre 2025. Se vuoi usare Python UDFs, crea la UDFs data precedente a quella data. Python esistente UDFs continuerà a funzionare normalmente. Per ulteriori informazioni, consulta il post del blog.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

PG_LAST_COPY_ID

Restituisce l'ID della query del comando COPY completato più recentemente nella sessione corrente. Se non sono stati eseguiti comandi COPY nella sessione corrente, PG_LAST_COPY_ID restituisce -1.

Il valore per PG_LAST_COPY_ID viene aggiornato quando il comando COPY inizia il processo di caricamento. Se il COPY ha esito negativo a causa di dati di carico non validi, l'ID COPY viene aggiornato, quindi è possibile utilizzare PG_LAST_COPY_ID quando si esegue una query sulla tabella STL_LOAD_ERRORS. Se si esegue il rollback della transazione COPY, l'ID COPY non viene aggiornato.

L'ID COPY non viene aggiornato se il comando COPY ha esisto negativo a causa di un errore che si verifica prima dell'inizio del processo di caricamento, come ad esempio un errore di sintassi, un errore di accesso, credenziali non valide o privilegi insufficienti. L'ID COPY non viene aggiornato se COPY ha esito negativo durante la fase di compressione dell'analisi, che inizia dopo una connessione riuscita, ma prima del caricamento dei dati.

Sintassi

pg_last_copy_id()

Tipo restituito

Restituisce un integer.

Esempio

La seguente query restituisce l'ID della query dal comando COPY più recente eseguito nella sessione corrente.

select pg_last_copy_id();

pg_last_copy_id
---------------
          5437
(1 row)

La query seguente collega STL_LOAD_ERRORS a STL_LOADERROR_DETAIL per visualizzare gli errori dei dettagli che si sono verificati durante il caricamento più recente nella sessione corrente:

select d.query, substring(d.filename,14,20), 
d.line_number as line, 
substring(d.value,1,16) as value,
substring(le.err_reason,1,48) as err_reason
from stl_loaderror_detail d, stl_load_errors le
where d.query = le.query
and d.query = pg_last_copy_id(); 

 query |    substring      | line |  value   |                    err_reason
-------+-------------------+------+----------+-------------------------------------------------
    558| allusers_pipe.txt |  251 | 251      | String contains invalid or unsupported UTF8 code
    558| allusers_pipe.txt |  251 | ZRU29FGR | String contains invalid or unsupported UTF8 code
    558| allusers_pipe.txt |  251 | Kaitlin  | String contains invalid or unsupported UTF8 code
    558| allusers_pipe.txt |  251 | Walter   | String contains invalid or unsupported UTF8 code