birbnetes/input-service
birbnetes/input-service
4
0
Fork 0
Code Pull Requests Releases Activity

temporary fiksz

Browse Source
This commit is contained in:
Torma Kristóf 2020-06-20 20:03:19 +02:00
parent 17b15f7e1e
commit 7dd66a895c
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/app.py
View File

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

6
src/resources.py
View File

@ -5,9 +5,9 @@ from xeger import Xeger
from flask_restful import Resource from flask_restful import Resource
from flask import request from flask import request
import requests import requests
import pika
from db import db from db import db
from models import SampleMetadata from models import SampleMetadata
from rabbitmqqueue import rabbitmq_channel
from schemas import SampleSchema, SampleMetadataSchema from schemas import SampleSchema, SampleMetadataSchema
from config import * from config import *
@ -76,6 +76,10 @@ class SampleResource(Resource):
soundfile, soundfile,
soundfile.content_type, soundfile.content_type,
{'Content-Length': soundfile.content_length})}).raise_for_status() {'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( rabbitmq_channel.basic_publish(
exchange=RABBITMQ_EXCHANGE, exchange=RABBITMQ_EXCHANGE,
routing_key='feature', routing_key='feature',