spacepaste

Paste details

reply | raw

  1.  
  2. #app/__init__.py
  3. from config import CELERY_BROKER_URL
  5. celery = Celery(__name__, broker=CELERY_BROKER_URL)
  8. def create_app(config_filename):
  9. app = Flask(__name__, static_folder='templates/static')
  10. app.config.from_object(config_filename)
  12. # Init Flask-SQLAlchemy
  13. from app.basemodels import db
  14. db.init_app(app)
  16. from app.users.views import users
  17. app.register_blueprint(users, url_prefix='/api/v1/users')
  19. from app.baseviews import login_required, login1, mail
  20. from flask import render_template, send_from_directory
  21. import os
  23. # Init Flask-Mail
  24. mail.init_app(app)
  26. celery.conf.update(app.config)
  28. @app.route('/')
  29. def index():
  30. return render_template('index.html')
  32. return app
  35. #app/celeries/views.py
  37. from app import celery
  39. @celery.task
  40. def send_async_email(cel):
  41. """Background task to send an email with Flask-Mail."""
  42. with app.app_context():
  43. print("Adding")
  44. cel.add(cel)
  47. class CreateListCeleries(Resource):
  48. """http://jsonapi.org/format/#fetching
  49. A server MUST respond to a successful request to fetch an individual resource or resource collection with a 200 OK response.
  50. A server MUST respond with 404 Not Found when processing a request to fetch a single resource that does not exist, except when the request warrants a 200 OK response with null as the primary data (as described above)
  51. a self link as part of the top-level links object"""
  53. def get(self):
  54. celeries_query = Celeries.query.all()
  55. results = schema.dump(celeries_query, many=True).data
  56. return results
  58. """http://jsonapi.org/format/#crud
  59. A resource can be created by sending a POST request to a URL that represents a collection of celeries. The request MUST include a single resource object as primary data. The resource object MUST contain at least a type member.
  60. If a POST request did not include a Client-Generated ID and the requested resource has been created successfully, the server MUST return a 201 Created status code"""
  62. def post(self):
  63. raw_dict = request.get_json(force=True)
  64. try:
  65. schema.validate(raw_dict)
  66. request_dict = raw_dict['data']['attributes']
  67. cel = Celeries(
  68. request_dict['hostname'], request_dict['ipaddress'],)
  72. send_async_email.apply_async(args=[cel], countdown=30)
  73. resp = jsonify({"error": "success"})
  74. resp.status_code = 201
  75. return resp
  79. except ValidationError as err:
  80. resp = jsonify({"error": err.messages})
  81. resp.status_code = 403
  82. return resp
  84. except SQLAlchemyError as e:
  85. db.session.rollback()
  86. resp = jsonify({"error": str(e)})
  87. resp.status_code = 403
  88. return resp
  93. api.add_resource(CreateListCeleries, '.json')
  94.  
Powered by spacepaste. Paste removal.