W jaki sposób można w pythonie zintegrować river rabbitmq pod elasticsearch?