RESTful Flask framework with MongoDB, Redis and Celery integrations
Project description
🙈 Dead Simple Web Framework 🙉
Overview:
A RESTful Flask framework with MongoDB, Redis and Celery integrations:
Backend:
- Flask [Framework]
- MongoDB [Database]
- Redis [Cache]
- Celery + RabbitMQ [Async Tasks]
Installing:
$ pip install dead-simple-framework
Configuration:
TODO - DOCS
Example Application (demo.py
):
* Celery must be running *
$ celery -A demo worker -l info
from dead_simple_framework import Application, Task_Manager, Database, API, Route, RouteHandler, DefaultRouteHandler, Task
from random import choice
sample_config = {
'routes': {
'insert': Route( # A route with automatic CRUD support
url='/insert',
collection='insert',
),
'demo': Route( # Another route with automatic CRUD support (with all options specified)
url='/demo', # The URL at which the server should handle requests
defaults=None, # Default parameters to pass to the handler function for this URL
database='db', # The database that should be passed to the handler function for this URL
collection='demo', # The collection that should be passed to the handler function for this URL
handler=DefaultRouteHandler() # A class specifying the handler functions to use based on the method used to access the URL
),
'refresh': Route( # Route with a handler for the GET method that runs an async task (in this case an API call)
url='/api/refresh',
handler=RouteHandler(
GET=lambda request, payload: str(Task_Manager.run_task('scheduled_call'))
)
),
'index': Route( # Route that fetches the cached latest result of an async task (in this case an API call)
url='/',
handler=RouteHandler(
GET=lambda request, payload: str(Task_Manager.get_result('scheduled_call'))
)
),
'add': Route( # Route that runs an async task (in this case simple addition) and fetches the result
url='/add',
handler=RouteHandler(
GET=lambda request, payload: str(Task_Manager.run_task('add'))
)
),
},
'tasks': { # Async tasks available to the Task_Manager [celery] to schedule or run
'add': { # Simple Addition Task (with default arguments)
'logic': lambda x,y: x + y,
'schedule': None,
'default_args': (2,2)
},
'insert': { # Periodic Database Insert Task
'logic': lambda res: Database(collection='insert').connect().insert_one({'test': 'doc', 'result': res}),
'schedule': {}, # Default - every minute
'depends_on': 'add' # Return value substituted for `res`
},
'call_api': { # API Call Task
'logic': lambda url, params=None: str(API.get(url, params, ignore_errors=False, retry_ms=10000, num_retries=20).content),
},
'scheduled_call': Task( # Make 3 parallel API calls
name='scheduled_call',
logic=lambda: Task_Manager.parallelize([['call_api', [x]] for x in get_websites(3)]),
schedule={}
)
}
}
WEBSITES =[
"http://www.google.com",
"http://www.yahoo.com",
"http://www.ebay.com",
"http://www.cnn.com",
"http://www.pbs.org",
"https://www.reddit.com/",
]
def get_websites(n):
_websites = [*WEBSITES]
res = []
for x in range(n):
res.append(choice(_websites))
_websites.remove(res[-1])
return res
app = Application(sample_config)
if __name__ == '__main__':
app.run()
-
Starts a local server at http://0.0.0.0:5000/
-
Serves CRUD operations for MongoDB collection
demo
at endpoint/demo
-
Runs an asynchronous chained value calculation and insert into the
insert
collection (viewable at/insert
) -
Runs asynchronous parallel API calls and displays the latest result at endpoint
/
(can be manually run at/api/refresh
)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for dead_simple_framework-0.8.8.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 20e0a471ae73749372e842f41e0b2006e166bafcfb3fdf22e8127649f6b2c603 |
|
MD5 | 5d4ec85425d3c7d13e9702069cf6f8d3 |
|
BLAKE2b-256 | 78e6ddb1859a7d5679f400a587300b317f6bc63052969a8a763432f045b18440 |
Close
Hashes for dead_simple_framework-0.8.8-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 318eaa5e52bee0429c44433934021ed7998c1c8f956851b3e74d35b66dff860f |
|
MD5 | f598ade5c632201d08825f25d6cee6d2 |
|
BLAKE2b-256 | 80e159728243c0562cc44b52ffa1be94871a44f5f93388f0e16f9e14c8f4a92b |