Skip to content

Commit 70d4b6b

Browse files
author
RamanjaneyuluIdavalapati
committed
supported bulk requests and Numpy, pickle protocols
1 parent cf34c5e commit 70d4b6b

3 files changed

Lines changed: 16 additions & 8 deletions

File tree

README.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ Quickly build API services to expose functionality in Python. `kwikapi.django` w
55
## Installation
66

77
```bash
8-
$ pip install kwikapi[django]
8+
$ pip3 install kwikapi[django]
99
```
1010

1111
## Usage
@@ -21,7 +21,7 @@ $ django-admin startproject django_kwikapi
2121
### Create an app in Django
2222

2323
```bash
24-
$ python manage.py startapp polls
24+
$ python3 manage.py startapp polls
2525
```
2626

2727
### Add your app name to settings.py
@@ -95,9 +95,9 @@ api.register(StandardCalc(), "v2")
9595
### Start Django
9696

9797
```bash
98-
$ python manage.py makemigrations
99-
$ python manage.py migrate
100-
$ python manage.py runserver 8888
98+
$ python3 manage.py makemigrations
99+
$ python3 manage.py migrate
100+
$ python3 manage.py runserver 8888
101101
```
102102

103103
### Make API request

kwikapi/django/kwikapi_django.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ def __init__(self, request):
3434
self.headers = {}
3535

3636
def write(self, data, proto, stream=False):
37-
super().write(data, proto, stream=stream)
37+
n, t = super().write(data, proto, stream=stream)
3838

3939
data = self._data
4040
r = StreamingHttpResponse(data) if stream else HttpResponse(data)
@@ -46,6 +46,7 @@ def write(self, data, proto, stream=False):
4646
self.headers = r
4747

4848
self.raw_response = self._response = r
49+
return n, t
4950

5051
def flush(self):
5152
self._response.flush()
@@ -56,5 +57,12 @@ def close(self):
5657
pass
5758

5859
class RequestHandler(BaseRequestHandler):
60+
PROTOCOL = BaseRequestHandler.DEFAULT_PROTOCOL
61+
5962
def handle_request(self, request):
60-
return super().handle_request(DjangoRequest(request))
63+
fn = lambda: super().handle_request(DjangoRequest(request))
64+
65+
if self.api.threadpool:
66+
self.api.threadpool.apply_async(fn)
67+
else:
68+
fn()

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
from setuptools import setup, find_packages
22

3-
version = '0.2.1'
3+
version = '0.2.2'
44
setup(
55
name="kwikapi-django",
66
version=version,

0 commit comments

Comments
 (0)