Message Queues

Message Queue that allows for events to be transmitted

Basic Queue

    

        
            
            
    
    from cdev.resources.simple.queue import Queue

myQueue = Queue('demo')

Integrating with a Serverless Function

You can use a Serverless Function to respond to the events from a Queue

    

        
            
            
    
    from cdev.resources.simple.queue import Queue
from cdev.resources.simple.xlambda import simple_function_annotation


myQueue = Queue('demo')
queue_event_trigger = myQueue.create_event_trigger()

@simple_function_annotation("demofunction", events=[queue_event_trigger], permissions=[myQueue.available_permissions.READ_EVENTS])
def hello_world(event,context):
  print(event)