src/app.py

@@ -5,6 +5,7 @@ from flask_restful import Api
 import sentry_sdk
 from sentry_sdk.integrations.flask import FlaskIntegration
 
+import rabbitmqqueue
 from config import *
 from db import db
 from marshm import ma

src/resources.py

@@ -5,9 +5,9 @@ from xeger import Xeger
 from flask_restful import Resource
 from flask import request
 import requests
-import pika
 from db import db
 from models import SampleMetadata
+from rabbitmqqueue import rabbitmq_channel
 from schemas import SampleSchema, SampleMetadataSchema
 from config import *
 
@@ -76,10 +76,6 @@ class SampleResource(Resource):
                         soundfile,
                         soundfile.content_type,
                         {'Content-Length': soundfile.content_length})}).raise_for_status()
-            credentials = pika.PlainCredentials(RABBITMQ_USERNAME, RABBITMQ_PASSWORD)
-            rabbitmq = pika.BlockingConnection(pika.ConnectionParameters(host=RABBITMQ_HOST, credentials=credentials))
-            rabbitmq_channel = rabbitmq.channel()
-            rabbitmq_channel.exchange_declare(exchange=RABBITMQ_EXCHANGE, exchange_type='fanout')
             rabbitmq_channel.basic_publish(
                 exchange=RABBITMQ_EXCHANGE,
                 routing_key='feature',