forked from LiveCarta/BookConverter
[LAW-3158] domen defining via api
- automatically define domen for uploaded books from queue's message
This commit is contained in:
@@ -42,14 +42,15 @@ def convert_book(book_id, access, logger):
|
||||
# print('Book has been proceeded.')
|
||||
|
||||
|
||||
def callback(ch, method, properties, body, access, logger):
|
||||
def callback(ch, method, properties, body, logger):
|
||||
print(f'Message: {body}.')
|
||||
logger.info(f'Message: {body}.')
|
||||
try:
|
||||
data = json.loads(body)
|
||||
api_url = data['apiURL'] if 'apiURL' in data else None
|
||||
params = {
|
||||
'book_id': data['id'],
|
||||
'access': access,
|
||||
'access': Access(url=api_url),
|
||||
'logger': logger
|
||||
}
|
||||
|
||||
@@ -114,10 +115,9 @@ if __name__ == '__main__':
|
||||
logger.log(logging.ERROR, f'Queue {conf_param["queue"]} is not declared.')
|
||||
raise exc
|
||||
|
||||
acs = Access()
|
||||
channel.basic_consume(queue=conf_param['queue'],
|
||||
auto_ack=True,
|
||||
on_message_callback=partial(callback, access=acs, logger=logger))
|
||||
on_message_callback=partial(callback, logger=logger))
|
||||
logger.info('Connection has been established.')
|
||||
print('Waiting for messages...')
|
||||
logger.info('Waiting for messages...')
|
||||
|
||||
Reference in New Issue
Block a user