process_pubsub.py

Source: sunholo/pubsub/process_pubsub.py

Functions

process_pubsub_message(data: dict) -> tuple

Extracts message data and metadata from a Pub/Sub message for a Cloud Storage event.

Args: data (dict): The Pub/Sub message data.

Returns: tuple: A tuple containing the message data and attributes as metadata.

decode_pubsub_message(data: dict) -> tuple

Extracts message data and metadata from a Pub/Sub message.

Args: data (dict): The Pub/Sub message data.

Returns: tuple: A tuple containing the message data and attributes as metadata.