async def METHOD_NAME(partition_context, event):
    print(f"Received event from partition: {partition_context.partition_id}.")
    bytes_payload = b"".join(b for b in event.body)
    print(f'The received bytes of the EventData is {bytes_payload!r}.')
    # Use the decode method to decode the payload of the event.
    # The decode method will extract the schema id from the content_type, and automatically retrieve the Json Schema
    # from the Schema Registry Service. The schema will be cached locally for future usage.
    decoded_content= await json_schema_encoder.decode(event)
    print(f'The dict content after decoding is {decoded_content}')