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