Erweiterung „pg_azure_storage“

GILT FÜR: Azure Cosmos DB for PostgreSQL (unterstützt von der Citus-Datenbankerweiterung auf PostgreSQL)

Mit der Erweiterung „pg_azure_storage“ können Sie Daten in mehreren Dateiformaten direkt aus Azure Blob Storage in Ihren Azure Cosmos DB for PostgreSQL-Cluster laden. Durch aktivieren der Erweiterung werden auch neue Funktionen des COPY-Befehls freigeschaltet. Container mit der Zugriffsebene „Privat“ oder „Blob“ erfordern das Hinzufügen eines privaten Zugriffsschlüssels.

Sie können die Erweiterung erstellen, indem Sie Folgendes ausführen:

SELECT create_extension('azure_storage');

azure_storage.account_add

Die Funktion ermöglicht das Hinzufügen des Zugriffs auf ein Speicherkonto.

azure_storage.account_add
        (account_name_p text
        ,account_key_p text);

Argumente

account_name_p

Ein Azure Blob Storage (ABS)-Konto enthält alle Ihre ABS-Objekte: Blobs, Dateien, Warteschlangen und Tabellen. Das Speicherkonto stellt einen eindeutigen Namespace für Ihr ABS bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

account_key_p

Ihre Azure Blob Storage (ABS)-Zugriffsschlüssel ähneln einem Stammkennwort für das Speicherkonto. Achten Sie darauf, die Zugriffsschlüssel immer gut zu schützen. Verwenden Sie Azure Key Vault zum sicheren Verwalten und Rotieren Ihrer Schlüssel. Der Kontoschlüssel wird in einer Tabelle gespeichert, auf die der postgres-Superuser, azure_storage_admin und alle Rolle, denen diese Administratorberechtigungen gewährt werden, zugreifen können. Um zu ermitteln, welche Speicherkonten vorhanden sind, verwenden Sie die Funktion „account_list“.

azure_storage.account_remove

Die Funktion ermöglicht das Aufheben des Kontozugriffs auf das Speicherkonto.

azure_storage.account_remove
        (account_name_p text);

Argumente

account_name_p

Das Azure Blob Storage (ABS)-Konto enthält alle Ihre ABS-Objekte: Blobs, Dateien, Warteschlangen und Tabellen. Das Speicherkonto stellt einen eindeutigen Namespace für Ihr ABS bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

azure_storage.account_user_add

Die Funktion ermöglicht das Hinzufügen des Zugriffs für eine Rolle zu einem Speicherkonto.

azure_storage.account_user_add
        ( account_name_p text
        , user_p regrole);

Argumente

account_name_p

Ein Azure Blob Storage (ABS)-Konto enthält alle Ihre ABS-Objekte: Blobs, Dateien, Warteschlangen und Tabellen. Das Speicherkonto stellt einen eindeutigen Namespace für Ihr ABS bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

user_p

Eine Rolle, die vom Benutzer erstellt wurde, der im Cluster sichtbar ist.

azure_storage.account_user_remove

Die Funktion ermöglicht das Entfernen des Zugriffs für eine Rolle auf ein Speicherkonto.

azure_storage.account_user_remove
        (account_name_p text
        ,user_p regrole);

Argumente

account_name_p

Ein Azure Blob Storage (ABS)-Konto enthält alle Ihre ABS-Objekte: Blobs, Dateien, Warteschlangen und Tabellen. Das Speicherkonto stellt einen eindeutigen Namespace für Ihr ABS bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

user_p

Eine Rolle, die vom Benutzer erstellt wurde, der im Cluster sichtbar ist.

azure_storage.account_list

Die Funktion listet das Konto und die Rolle auf, das Zugriff auf Azure Blob Storage hat.

azure_storage.account_list
        (OUT account_name text
        ,OUT allowed_users regrole[]
        )
Returns TABLE;

Argumente

account_name

Das Azure Blob Storage (ABS)-Konto enthält alle Ihre ABS-Objekte: Blobs, Dateien, Warteschlangen und Tabellen. Das Speicherkonto stellt einen eindeutigen Namespace für Ihr ABS bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

allowed_users

Listet die Benutzer auf, die Zugriff auf den Azure-Blobspeicher haben.

Rückgabetyp

TABLE

azure_storage.blob_list

Die Funktion listet die verfügbaren Blobdateien in einem Benutzercontainer mit ihren Eigenschaften auf.

azure_storage.blob_list
        (account_name text
        ,container_name text
        ,prefix text DEFAULT ''::text
        ,OUT path text
        ,OUT bytes bigint
        ,OUT last_modified timestamp with time zone
        ,OUT etag text
        ,OUT content_type text
        ,OUT content_encoding text
        ,OUT content_hash text
        )
Returns SETOF record;

Argumente

account_name

Das storage account name stellt einen eindeutigen Namespace für Ihre Azure Storage-Daten bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

container_name

Ein Container dient zum Organisieren einer Gruppe von Blobs (ähnlich wie ein Verzeichnis in einem Dateisystem). Ein Speicherkonto kann eine unbegrenzte Anzahl von Containern enthalten, und in einem Container kann eine unbegrenzte Anzahl von Blobs gespeichert werden. Ein Containername muss ein gültiger DNS-Name sein, da er Teil des eindeutigen URI ist, der für die Adressierung des Containers oder seiner Blobs verwendet wird. Befolgen Sie diese Regeln, wenn Sie einen Container benennen:

• Containernamen können zwischen 3 und 63 Zeichen lang sein.
• Containernamen müssen mit einem Buchstaben oder einer Zahl beginnen und dürfen nur Kleinbuchstaben, Zahlen und Bindestriche (-) enthalten.
• Zwei oder mehr aufeinanderfolgende Bindestriche sind in Containernamen nicht zulässig.

Der URI für einen Container ähnelt https://myaccount.blob.core.windows.net/mycontainer.

prefix

Gibt eine Datei aus dem Blobcontainer mit übereinstimmenden Zeichenfolgeninitialen zurück.

path

Vollständig qualifizierter Pfad des Azure-Blobverzeichnisses.

Byte

Größe des Dateiobjekts in Bytes.

last_modified

Letzte Änderung der Dateiinhalte am:

etag

Eine ETag-Eigenschaft wird für die optimistische Parallelität während Updates verwendet. Es handelt sich nicht um einen Zeitstempel, da es eine andere Eigenschaft namens „Timestamp“ gibt, die die letzte Aktualisierung eines Datensatzes speichert. Wenn Sie beispielsweise eine Entität laden und sie aktualisieren möchten, muss das ETag mit dem übereinstimmen, was derzeit gespeichert ist. Das Festlegen des entsprechenden ETags ist wichtig, denn wenn mehrere Benutzer dasselbe Element bearbeiten, sollen sie die Änderungen der anderen nicht überschreiben.

content_type

Das Blobobjekt stellt ein Blob dar, bei dem es sich um ein dateiähnliches Objekt mit unveränderlichen Rohdaten handelt. Sie können als Text- oder Binärdaten gelesen oder in einen ReadableStream konvertiert werden, sodass die Methoden für die Verarbeitung der Daten verwendet werden können. Blobs können Daten darstellen, die nicht unbedingt in einem nativen JavaScript-Format vorliegen.

content_encoding

Mit Azure Storage können Sie die Eigenschaft „Content-Encoding“ für ein Blob definieren. Für komprimierte Inhalte können Sie die Eigenschaft auf „GZIP“ festlegen. Wenn der Browser auf den Inhalt zugreift, dekomprimiert er den Inhalt automatisch.

content_hash

Mithilfe des Hash wird die Integrität des BLOB während der Übertragung überprüft. Bei Angabe dieses Headers überprüft der Speicherdienst den Hash, der zusammen mit dem gesendeten eingegangen ist. Wenn die beiden Hashs nicht übereinstimmen, schlägt der Vorgang mit Fehlercode 400 (Ungültige Anforderung) fehl.

Rückgabetyp

SETOF-Datensatz

azure_storage.blob_get

Die Funktion ermöglicht das Laden des Inhalts der Datei\Dateien aus dem Container, wobei Unterstützung für das Filtern oder Bearbeiten von Daten vor dem Import hinzugefügt wurde.

azure_storage.blob_get
        (account_name text
        ,container_name text
        ,path text
        ,decoder text DEFAULT 'auto'::text
        ,compression text DEFAULT 'auto'::text
        ,options jsonb DEFAULT NULL::jsonb
        )
RETURNS SETOF record;

Es gibt eine überladene Version der Funktion, die den Rec-Parameter enthält, mit dem Sie den Ausgabeformatdatensatz bequem definieren können.

azure_storage.blob_get
        (account_name text
        ,container_name text
        ,path text
        ,rec anyelement
        ,decoder text DEFAULT 'auto'::text
        ,compression text DEFAULT 'auto'::text
        ,options jsonb DEFAULT NULL::jsonb
        )
RETURNS SETOF anyelement;

Argumente

account

Das Speicherkonto stellt einen eindeutigen Namespace für Ihre Azure Storage-Daten bereit, auf den von jedem Ort der Welt aus über HTTPS zugegriffen werden kann.

Container

Ein Container dient zum Organisieren einer Gruppe von Blobs (ähnlich wie ein Verzeichnis in einem Dateisystem). Ein Speicherkonto kann eine unbegrenzte Anzahl von Containern enthalten, und in einem Container kann eine unbegrenzte Anzahl von Blobs gespeichert werden. Ein Containername muss ein gültiger DNS-Name sein, da er Teil des eindeutigen URI ist, der für die Adressierung des Containers oder seiner Blobs verwendet wird.

path

Ein Blobname, der im Container vorhanden ist.

rrec

Definieren Sie die Datensatzausgabestruktur.

Decoder

Geben Sie an, ob der Blobformat-Decoder auf „auto (Standard)“ oder auf einen der folgenden Werte festgelegt werden kann

Decoderbeschreibung

Format	Beschreibung
csv	Durch Komma getrenntes Format für Werte, das von PostgreSQL COPY verwendet wird
tsv	Durch Tabstopp getrennte Werte – das Standardformat PostgreSQL COPY
BINARY	Format Binary PostgreSQL COPY
text	Datei mit einem einzelnen Textwert (z. B. große JSON oder XML)

compression

Definiert das Komprimierungsformat. Verfügbare Optionen sind auto, gzip & none. Option „auto (Standard)“ errät die Komprimierung basierend auf der Dateierweiterung (.gz == gzip). Die Option „none“ erzwingt, die Erweiterung zu ignorieren und nicht zu decodieren. gzip hingegen erzwingt die Verwendung des gzip-Decoders (wenn Sie eine gzipped-Datei mit einer nicht standardmäßigen Erweiterung haben). Derzeit werden keine anderen Komprimierungsformate für die Erweiterung unterstützt.

Optionen

Für die Verarbeitung von benutzerdefinierten Kopfzeilen, benutzerdefinierten Trennzeichen, Escapezeichen usw. funktioniert options auf ähnliche Weise wie der Befehl „COPY“ in PostgreSQL, wobei der Parameter für die Funktion „blob_get“ verwendet wird.

Rückgabetyp

SETOF Record / anyelement

azure_storage.options_csv_get

Die Funktion fungiert als Hilfsfunktion, die als Parameter in blob_get aufgerufen wird, was nützlich für das Decodieren des CSV-Inhalts ist.

azure_storage.options_csv_get
        (delimiter text DEFAULT NULL::text
        ,null_string text DEFAULT NULL::text
        ,header boolean DEFAULT NULL::boolean
        ,quote text DEFAULT NULL::text
        ,escape text DEFAULT NULL::text
        ,force_not_null text[] DEFAULT NULL::text[]
        ,force_null text[] DEFAULT NULL::text[]
        ,content_encoding text DEFAULT NULL::text
        )
Returns jsonb;

Argumente

Trennzeichen

Gibt das Zeichen an, das Spalten innerhalb jeder Zeile (Linie) der Datei trennt. Die Standardeinstellung ist ein Tabulatorzeichen im Textformat, ein Komma im CSV-Format. Es muss ein einzelnes Ein-Byte-Zeichen sein.

null_string

Gibt die Zeichenfolge an, die einen NULL-Wert darstellt. Der Standardwert ist \N (umgekehrter Schrägstrich-N) im Textformat und eine leere Zeichenfolge ohne Anführungszeichen im CSV-Format. Möglicherweise bevorzugen Sie eine leere Zeichenfolge auch im Textformat, wenn Sie Null nicht von leeren Zeichenfolgen unterscheiden möchten.

header

Gibt an, dass die Datei eine Kopfzeile mit den Namen jeder Spalte in der Datei enthält. Bei der Ausgabe enthält die erste Zeile die Spaltennamen aus der Tabelle.

Quote

Gibt das Anführungszeichen an, das verwendet werden soll, wenn ein Datenwert in Anführungszeichen gesetzt wird. Standardmäßig sind dies doppelte Anführungszeichen. Es muss ein einzelnes Ein-Byte-Zeichen sein.

Escape

Gibt das Zeichen an, das vor einem Datenzeichen angezeigt werden soll, das dem QUOTE-Wert entspricht. Der Standardwert ist identisch mit dem QUOTE-Wert (sodass das Anführungszeichen verdoppelt werden, wenn es in den Daten angezeigt wird). Es muss ein einzelnes Ein-Byte-Zeichen sein.

force_not_null

Die Werte der angegebenen Spalten werden nicht mit der NULL-Zeichenfolge abgestimmt. Im Standardfall, in dem die NULL-Zeichenfolge leer ist, bedeutet dies, dass leere Werte als Zeichenfolgen der Länge null und nicht als NULLEN gelesen werden, auch wenn sie nicht in Anführungszeichen stehen.

force_null

Die Werte der angegebenen Spalten werden mit der NULL-Zeichenfolge abgestimmt, auch wenn sie in Anführungszeichen angegeben wurde, und der Wert wird auf NULL festgelegt, wenn eine Übereinstimmung gefunden wird. Im Standardfall, in dem die NULL-Zeichenfolge leer ist, konvertiert sie eine leere Zeichenfolge in Anführungszeichen in NULL.

content_encoding

Gibt an, dass die Datei als „encoding_name“ codiert ist. Wenn die Option ausgelassen wird, wird die aktuelle Clientcodierung verwendet.

Rückgabetyp

jsonb

azure_storage.options_copy

Die Funktion fungiert als Hilfsfunktion, die als Parameter innerhalb von blob_get aufgerufen wird.

azure_storage.options_copy
        (delimiter text DEFAULT NULL::text
        ,null_string text DEFAULT NULL::text
        ,header boolean DEFAULT NULL::boolean
        ,quote text DEFAULT NULL::text
        ,escape text DEFAULT NULL::text
        ,force_quote text[] DEFAULT NULL::text[]
        ,force_not_null text[] DEFAULT NULL::text[]
        ,force_null text[] DEFAULT NULL::text[]
        ,content_encoding text DEFAULT NULL::text
        )
Returns jsonb;

Argumente

Trennzeichen

Gibt das Zeichen an, das Spalten innerhalb jeder Zeile (Linie) der Datei trennt. Die Standardeinstellung ist ein Tabulatorzeichen im Textformat, ein Komma im CSV-Format. Es muss ein einzelnes Ein-Byte-Zeichen sein.

null_string

Gibt die Zeichenfolge an, die einen NULL-Wert darstellt. Der Standardwert ist \N (umgekehrter Schrägstrich-N) im Textformat und eine leere Zeichenfolge ohne Anführungszeichen im CSV-Format. Möglicherweise bevorzugen Sie eine leere Zeichenfolge auch im Textformat, wenn Sie Null nicht von leeren Zeichenfolgen unterscheiden möchten.

header

Gibt an, dass die Datei eine Kopfzeile mit den Namen jeder Spalte in der Datei enthält. Bei der Ausgabe enthält die erste Zeile die Spaltennamen aus der Tabelle.

Quote

Gibt das Anführungszeichen an, das verwendet werden soll, wenn ein Datenwert in Anführungszeichen gesetzt wird. Standardmäßig sind dies doppelte Anführungszeichen. Es muss ein einzelnes Ein-Byte-Zeichen sein.

Escape

Gibt das Zeichen an, das vor einem Datenzeichen angezeigt werden soll, das dem QUOTE-Wert entspricht. Der Standardwert ist identisch mit dem QUOTE-Wert (sodass das Anführungszeichen verdoppelt werden, wenn es in den Daten angezeigt wird). Es muss ein einzelnes Ein-Byte-Zeichen sein.

force_quote

Erzwingt die Verwendung von Anführungszeichen für alle Nicht-NULL-Werte in jeder angegebenen Spalte. Die NULL-Ausgabe wird nie in Anführungszeichen gesetzt. Wenn * angegeben ist, werden in allen Spalten Werte ohne NULL in Anführungszeichen gesetzt.

force_not_null

Die Werte der angegebenen Spalten werden nicht mit der NULL-Zeichenfolge abgestimmt. Im Standardfall, in dem die NULL-Zeichenfolge leer ist, bedeutet dies, dass leere Werte als Zeichenfolgen der Länge null und nicht als NULLEN gelesen werden, auch wenn sie nicht in Anführungszeichen stehen.

force_null

Die Werte der angegebenen Spalten werden mit der NULL-Zeichenfolge abgestimmt, auch wenn sie in Anführungszeichen angegeben wurde, und der Wert wird auf NULL festgelegt, wenn eine Übereinstimmung gefunden wird. Im Standardfall, in dem die NULL-Zeichenfolge leer ist, konvertiert sie eine leere Zeichenfolge in Anführungszeichen in NULL.

content_encoding

Gibt an, dass die Datei als „encoding_name“ codiert ist. Wenn die Option ausgelassen wird, wird die aktuelle Clientcodierung verwendet.

Rückgabetyp

jsonb

azure_storage.options_tsv

Die Funktion fungiert als Hilfsfunktion, die als Parameter innerhalb von blob_get aufgerufen wird. Sie ist nützlich, um den TSV-Inhalt zu decodieren.

azure_storage.options_tsv
        (delimiter text DEFAULT NULL::text
        ,null_string text DEFAULT NULL::text
        ,content_encoding text DEFAULT NULL::text
        )
Returns jsonb;

Argumente

Trennzeichen

Gibt das Zeichen an, das Spalten innerhalb jeder Zeile (Linie) der Datei trennt. Die Standardeinstellung ist ein Tabulatorzeichen im Textformat, ein Komma im CSV-Format. Es muss ein einzelnes Ein-Byte-Zeichen sein.

null_string

Gibt die Zeichenfolge an, die einen NULL-Wert darstellt. Der Standardwert ist \N (umgekehrter Schrägstrich-N) im Textformat und eine leere Zeichenfolge ohne Anführungszeichen im CSV-Format. Möglicherweise bevorzugen Sie eine leere Zeichenfolge auch im Textformat, wenn Sie Null nicht von leeren Zeichenfolgen unterscheiden möchten.

content_encoding

Gibt an, dass die Datei als „encoding_name“ codiert ist. Wenn die Option ausgelassen wird, wird die aktuelle Clientcodierung verwendet.

Rückgabetyp

jsonb

azure_storage.options_binary

Die Funktion fungiert als Hilfsfunktion, die als Parameter innerhalb von blob_get aufgerufen wird. Sie ist nützlich, um den binären Inhalt zu decodieren.

azure_storage.options_binary
        (content_encoding text DEFAULT NULL::text)
Returns jsonb;

Argumente

content_encoding

Gibt an, dass die Datei als „encoding_name“ codiert ist. Wenn diese Option weggelassen wird, wird die aktuelle Clientcodierung verwendet.

Rückgabetyp

jsonb

citus userBerechtigungenazure_storage_admin Jetzt können Sie Container auflisten, die für diesen Speicher auf die Zugriffsebenen „Privat“ und „Blob“ festlegt sind, aber nur als , dem die -Rolle zugewiesen wurde. Wenn Sie einen neuen Benutzer names „Support“ erstellen, ist es standardmäßig nicht zulässig, auf Containerinhalte zuzugreifen.

Beispiele

In den verwendeten Beispielen wird das Azure-Beispielspeicherkonto „(pgquickstart)“ mit benutzerdefinierten Dateien verwendet, die zur Abdeckung verschiedener Anwendungsfälle hochgeladen wurden. Sie können damit beginnen, eine Tabelle zu erstellen, die für den gesamten Satz von Beispielen verwendet wird.

CREATE TABLE IF NOT EXISTS public.events
        (
         event_id bigint
        ,event_type text
        ,event_public boolean
        ,repo_id bigint
        ,payload jsonb
        ,repo jsonb
        ,user_id bigint
        ,org jsonb
        ,created_at timestamp without time zone
        );

Hinzufügen des Zugriffsschlüssels des Speicherkontos (obligatorisch für Zugriffsebene = privat)

Das Beispiel veranschaulicht das Hinzufügen eines Zugriffsschlüssels für das Speicherkonto, um Zugriff auf Abfragen aus einer Sitzung im Azure Cosmos DB for Postgres-Cluster zu erhalten.

SELECT azure_storage.account_add('pgquickstart', 'SECRET_ACCESS_KEY');

Entfernen des Zugriffsschlüssels des Speicherkontos

Das Beispiel veranschaulicht das Entfernen des Zugriffsschlüssels für ein Speicherkonto. Diese Aktion führt dazu, dass der Zugriff auf Dateien entfernt wird, die im privaten Bucket im Container gehostet werden.

SELECT azure_storage.account_remove('pgquickstart');

Hinzufügen des Zugriffs für eine Rolle zu Azure Blob-Speicher

SELECT * FROM azure_storage.account_user_add('pgquickstart', 'support');

Auflisten aller Rollen mit Zugriff auf Azure Blob-Speicher

SELECT * FROM azure_storage.account_list();

Entfernen der Rollen mit Zugriff auf Azure Blob-Speicher

SELECT * FROM azure_storage.account_user_remove('pgquickstart', 'support');

Auflisten der Objekte in einem public-Container

SELECT * FROM azure_storage.blob_list('pgquickstart','publiccontainer');

Auflisten der Objekte in einem private-Container

SELECT * FROM azure_storage.blob_list('pgquickstart','privatecontainer');

Auflisten der Objekte mit bestimmten Zeichenfolgeninitialen im öffentlichen Container

SELECT * FROM azure_storage.blob_list('pgquickstart','publiccontainer','e');

Alternativ

SELECT * FROM azure_storage.blob_list('pgquickstart','publiccontainer') WHERE path LIKE 'e%';

Lesen von Inhalten aus einem Objekt in einem Container

Die Funktion „blob_get“ ruft eine Datei aus dem Blobspeicher ab. Damit blob_get weiß, wie die Daten analysiert werden, können Sie einen Wert (NULL::table_name) übergeben, der dasselbe Format wie die Datei hat.

SELECT * FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events.csv.gz'
        , NULL::events)
LIMIT 5;

Alternativ können wir die Spalten in der FROM-Klausel explizit definieren.

SELECT * FROM azure_storage.blob_get('pgquickstart','publiccontainer','events.csv')
AS res (
         event_id BIGINT
        ,event_type TEXT
        ,event_public BOOLEAN
        ,repo_id BIGINT
        ,payload JSONB
        ,repo JSONB
        ,user_id BIGINT
        ,org JSONB
        ,created_at TIMESTAMP WITHOUT TIME ZONE)
LIMIT 5;

Verwenden von Decoderoption

Dieses Beispiel beschreibt die Verwendung der decoder-Option. Normalerweise wird das Format aus der Erweiterung der Datei abgeleitet, aber wenn die Dateiinhalte keine übereinstimmende Erweiterung aufweisen, können Sie das Decoderargument übergeben.

SELECT * FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events'
        , NULL::events
        , decoder := 'csv')
LIMIT 5;

Verwenden der Komprimierung mit Decoderoption

Das Beispiel zeigt, wie Sie die Verwendung der gzip-Komprimierung für eine gzip-komprimierte Datei ohne gz-Standarderweiterung erzwingen.

SELECT * FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events-compressed'
        , NULL::events
        , decoder := 'csv'
        , compression := 'gzip')
LIMIT 5;

Importieren gefilterter Inhalte und Ändern vor dem Laden aus dem CSV-Formatobjekt

Das Beispiel veranschaulicht die Möglichkeit, den Inhalt zu filtern und zu ändern, der aus einem Objekt im Container importiert wird, bevor er in eine SQL-Tabelle geladen wird.

SELECT concat('P-',event_id::text) FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events.csv'
        , NULL::events)
WHERE event_type='PushEvent'
LIMIT 5;

Abfragen von Inhalten aus einer Datei mit Kopfzeilen, benutzerdefinierten Trennzeichen, Escapezeichen

Sie können benutzerdefinierte Trennzeichen und Escapezeichen verwenden, indem Sie das Ergebnis von azure_storage.options_copy an das options-Argument übergeben.

SELECT * FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events_pipe.csv'
        ,NULL::events
        ,options := azure_storage.options_csv_get(delimiter := '|' , header := 'true')
        );

Aggregationsabfrage zum Inhalt eines Objekts im Container

Auf diese Weise können Sie Daten abfragen, ohne sie zu importieren.

SELECT event_type,COUNT(1) FROM azure_storage.blob_get
        ('pgquickstart'
        ,'publiccontainer'
        ,'events.csv'
        , NULL::events)
GROUP BY event_type
ORDER BY 2 DESC
LIMIT 5;

Nächste Schritte