sample-py-dapr.py

from dapr.clients import DaprClient
from azure.functions import func

# Function to get accessories
@app.route('/accessories', methods=['GET'])
def accessories_get():
    with DaprClient() as d:
        data = d.get_state(store_name='accessories')
        return json.dumps(data)

# Function to create accessories
@app.route('accessories/<int:accessories_id>', methods=['PUT'])
def accessories_put_by_id(accessories_id: int):
    with DaprClient() as d:
        req_data = {
            'id': accessories_id,
            'message': 'new accessory'
        }

        func.context.log(f'Adding accessory to database: {accessories_id}')

        d.invoke_binding('dataBinding', 'create', json.dumps(req_data))

        return f'Accessories = int({accessories_id})'