RESTful Flask framework with MongoDB, Redis, Celery, Sentry and Slack 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-1.0.6.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 21b1f5e6d766db9357a8aeb562f9b1a2df5ef8b03fa2b01924cc720ad602ed22 |
|
MD5 | 9a0ef33339abdeccbfbe5ce29b035165 |
|
BLAKE2b-256 | 9ade47aa749bada00662a1e658ed78d78145d765c042589334f99857b00d7f12 |
Close
Hashes for dead_simple_framework-1.0.6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2557a9923380ac778a1658ea59cc8ef243345f17329eb0b80e5c14a9544617d3 |
|
MD5 | a326a7499f7b32143f4bc584d585c494 |
|
BLAKE2b-256 | b4a8f46bc8311b17a9e4ddde7bc33a0cd26b3dd619dde665be64eac8b0180a9f |