Skip to content
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
193 lines (139 sloc) 5.9 KB
# - using Marshmallow serialization with Flask-Restless
# Copyright 2011 Lincoln de Sousa <>.
# Copyright 2012, 2013, 2014, 2015, 2016 Jeffrey Finkelstein
# <> and contributors.
# This file is part of Flask-Restless.
# Flask-Restless is distributed under both the GNU Affero General Public
# License version 3 and under the 3-clause BSD license. For more
# information, see LICENSE.AGPL and LICENSE.BSD.
"""Using Marshmallow for serialization in Flask-Restless.
This script is an example of using `Marshmallow`_ to provide custom
serialization (and the corresponding deserialization) from SQLAlchemy
models to Python dictionaries that will eventually become JSON API
responses to the client. Specifically, this example uses the
`marshmallow-jsonapi`_ library to create serialization/deserialization
functions for use with Flask-Restless.
There are some problems with this approach. You will need to specify
some configuration twice, once for marshmallow-jsonapi and once for
Flask-Restless. For example, you must provide a custom "collection name"
as both the class-level attribute :attr:`Meta.type_` and as the
*collection_name* keyword argument to :meth:`APIManager.create_api`. For
another example, you must specify the URLs for relationships and related
resources directly in the schema definition, and thus these must match
EXACTLY the URLs created by Flask-Restless. The URLs created by
Flask-Restless are fairly predictable, so this requirement, although not
ideal, should not be too challenging.
(This example might have used the `marshmallow-sqlalchemy`_ model to
mitigate some of these issues, but there does not seem to be an easy way
to combine these two Marshmallow layers together.)
To install the necessary requirements for this example, run::
pip install flask-restless flask-sqlalchemy marshmallow-jsonapi
To run this script from the current directory::
python -m custom_serialization
This will run a Flask server at ``http://localhost:5000``. You can then
make requests using any web client.
.. _Marshmallow:
.. _marshmallow-sqlalchemy:
.. _marshmallow-jsonapi:
from flask import Flask
from flask_restless import APIManager
from flask_restless import DefaultSerializer
from flask_restless import DefaultDeserializer
from flask_sqlalchemy import SQLAlchemy
from marshmallow import post_load
from marshmallow_jsonapi import fields
from marshmallow_jsonapi import Schema
# Flask application and database configuration
app = Flask(__name__)
app.config['DEBUG'] = True
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
db = SQLAlchemy(app)
# Flask-SQLAlchemy model definitions #
class Person(db.Model):
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.Unicode)
class Article(db.Model):
id = db.Column(db.Integer, primary_key=True)
title = db.Column(db.Unicode)
author_id = db.Column(db.Unicode, db.ForeignKey(
author = db.relationship(Person, backref=db.backref('articles'))
# Marshmallow schema definitions #
class PersonSchema(Schema):
class Meta:
model = Person
type_ = 'person'
sqla_session = db.session
strict = True
id = fields.Integer(dump_only=True)
name = fields.Str()
articles = fields.Relationship(
self_url_kwargs={'personid': '<id>'},
related_url_kwargs={'articleid': '<id>'},
def make_person(self, data):
return Person(**data)
class ArticleSchema(Schema):
class Meta:
model = Article
type_ = 'article'
sqla_session = db.session
strict = True
id = fields.Integer(dump_only=True)
title = fields.Str()
author = fields.Relationship(
self_url_kwargs={'articleid': '<id>'},
related_url_kwargs={'personid': '<id>'},
def make_article(self, data):
return Article(**data)
# Serializer and deserializer classes #
class MarshmallowSerializer(DefaultSerializer):
schema_class = None
def serialize(self, instance, only=None):
schema = self.schema_class(only=only)
return schema.dump(instance).data
def serialize_many(self, instances, only=None):
schema = self.schema_class(many=True, only=only)
return schema.dump(instances).data
class MarshmallowDeserializer(DefaultDeserializer):
schema_class = None
def deserialize(self, document):
schema = self.schema_class()
return schema.load(document).data
def deserialize_many(self, document):
schema = self.schema_class(many=True)
return schema.load(document).data
class PersonSerializer(MarshmallowSerializer):
schema_class = PersonSchema
class PersonDeserializer(MarshmallowDeserializer):
schema_class = PersonSchema
class ArticleSerializer(MarshmallowSerializer):
schema_class = ArticleSchema
class ArticleDeserializer(MarshmallowDeserializer):
schema_class = ArticleSchema
if __name__ == '__main__':
manager = APIManager(app, flask_sqlalchemy_db=db)
manager.create_api(Person, methods=['GET', 'POST'],
manager.create_api(Article, methods=['GET', 'POST'],
You can’t perform that action at this time.