路由

channel.basic_publish(
    exchange='direct_logs',
    routing_key='error',
    body='Error message'
)