atlan-collect / gateway / spreadhseet_svc / spreadsheet.py
spreadsheet.py
Raw
import pika, json

def upload_data(request, channel):
  try:
    data = json.loads(request.data)
    name = data.get('name')
    email = data.get('email')
    phone = data.get('phone')  
    
    message = {
        "name": name,
        "email": email,
        "phone": phone,
    }
    channel.basic_publish(
      exchange="",
      routing_key="spreadsheet",
      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 data, {err}", 500