atlan-collect / gateway / translator_svc / translator.py
translator.py
Raw
import pika, json

def translate_text(request, channel):
  
  try:
      data = json.loads(request.data)
      country = data.get('country')
      region = data.get('region')
      text = data.get('text')  
      email = data.get('email')
      print(data)
      message = {
          "region": region,
          "text": text,
          "country": country,
          "email": email
      }
      channel.basic_publish(
        exchange="",
        routing_key="translator",
        body= json.dumps(message),
        properties=pika.BasicProperties(
          delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE
        ),
      )
      return "success"
  except Exception as err:
    print(err)
    return f"error transfering your request, {err}", 500