rele
rele copied to clipboard
mercadona
Easy to use Google Pub/Sub
### :tophat: What? Allow custom deserializers other than the default json deserializer. ### :thinking: Why? Some of GCP's pub/sub notifications have messages that are simple strings which can't be deserialized...
Currently, async functions can't be used with the @sub context manager. ```python @sub(topic='my-topic'): async def async_handler(data, **kwargs): print('data', data) ``` If you try, you'll get the following error. ```python Configuring...
Currently rele's subscription model only supports consuming messages that are json deserializable. Unfortunately some of GCP's core services publish non-json messages. For example, the gcp dicom store publishes notifications to...
### :tophat: What? Set a default value for subscriptions message retention by default to 24 hours. You can set a custom value by specifying the parameter MESSAGE_RETENTION_DURATION in your Django...
We want to have a way to set custom options for clients, in order to being able to instead using public connection for Gcloud api use the [interconnect](https://cloud.google.com/network-connectivity/docs/interconnect) network. The...
We have realised consumers stucks in the `Re-established stream` when we lose the network connectivity more than 1 minute and after recover it. This is an example: ``` {"levelname": "ERROR",...
Right now rele discovers the subscriptions from the packages in the [current path](https://github.com/mercadona/rele/blob/9dc6a68ae06cc710dda5bc3025d917b50019bd7b/rele/discover.py#L44). We want the ability to discover the subscriptions from a package that is installed by the pip....
Hey all! I got this email last night. The link [here](https://readthedocs.org/dashboard/mercadonarele/integrations/88524/), needs to be updated. Also, I should transfer ownership of the read the docs integration with someone 😜 ....
### :tophat: What? Catch PermissionDenied and continue with updating the existing subscription if necessary. ### :thinking: Why? If the subscription already exists (because it was pre-created) and the service account...
I am using rele with GCP. I want to use a minimum permission principle, where I allow subscribers to only subscribe to the topics that I allow them to. For...