There is no requirements.txt and installation fails:

$ python3 setup.py install
Traceback (most recent call last):
  File "setup.py", line 10, in <module>
    import build
  File "/Users/r0fls/Documents/code/foss/japronto/build.py", line 11, in <module>
    import pytoml
ImportError: No module named 'pytoml'

Installing this way should install the dependencies.

I installed Japronto on OSX via setup.py, and attempted to run the hello world example. The example threw an error when I tried to connect to it via my browser or wrk. The error message was

Worker exited with code -4!

Note: I am using a 2010 Macbook pro with Sierra, and received this error straight from the fresh git clone. The installation ran fine but I received a few warnings about uvloop.

I tried a very basic tutorial at https://github.com/squeaky-pl/japronto/blob/master/tutorial/1_hello.md with pip 10.0.1, japronto 0.1.1, uvloop 0.9.1, and ujson 1.35 on Ubuntu 18.04 64-bit running Python 3.6.5. I have tried the latest Sanic with this uvloop and it doesn't cause any errors with it.

When I start the server, it instantly shows this in the terminal:
Accepting connections on http://0.0.0.0:8080

but when I go to that in my browser, the browser is stuck in a loading animation and it immediately errors out in the terminal with this output:

Exception in callback UVTransport._call_connection_made
handle: <Handle UVTransport._call_connection_made>
Traceback (most recent call last):
  File "uvloop/cbhandles.pyx", line 52, in uvloop.loop.Handle._run
  File "uvloop/handles/tcp.pyx", line 149, in uvloop.loop.TCPTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 156, in uvloop.loop.UVBaseTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 153, in uvloop.loop.UVBaseTransport._call_connection_made
SystemError: NULL result without error in PyObject_Call
Exception in callback UVTransport._call_connection_made
handle: <Handle UVTransport._call_connection_made>
Traceback (most recent call last):
  File "uvloop/cbhandles.pyx", line 52, in uvloop.loop.Handle._run
  File "uvloop/handles/tcp.pyx", line 149, in uvloop.loop.TCPTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 156, in uvloop.loop.UVBaseTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 153, in uvloop.loop.UVBaseTransport._call_connection_made
SystemError: NULL result without error in PyObject_Call

I know this project hasn't been maintained in a while, but a bunch of benchmarking sites like https://github.com/tbrand/which_is_the_fastest are starting to list it as the best Python server competing with Rust, Go, and Node.

Will there be updates to this in the near future and if so, will there be more testing?

I am doing tests since its benchmark seems to me too high, I am doing the benchmark and they give me very different results to those that appear in the image:

CPU: Intel (R) Core (TM) i7-6700 CPU @ 3.40 GHz

japronto

docker run williamyeh/wrk -c 200 -t 1 -d 4 http://172.17.0.2:8080/ Running 4s test @ http://172.17.0.2:8080/ 1 threads and 200 connections Thread Stats Avg Stdev Max +/- Stdev Latency 0.85ms 307.50us 3.17ms 70.66% Req/Sec 227.29k 3.84k 232.01k 75.00% 904138 requests in 4.01s, 79.33MB read Requests/sec: 225703.67 Transfer/sec: 19.80MB

meinheld

docker run williamyeh/wrk -c 200 -t 1 -d 4 http://172.17.0.2:8080/ Running 4s test @ http://172.17.0.2:8080/ 1 threads and 200 connections Thread Stats Avg Stdev Max +/- Stdev Latency 5.03ms 9.90ms 215.48ms 99.25% Req/Sec 46.38k 768.92 48.44k 75.00% 184537 requests in 4.01s, 31.15MB read Requests/sec: 46049.91 Transfer/sec: 7.77MB

I have checked the post in https://medium.freecodecamp.org/million-requests-per-second-with-python-95c137af319 and git clone source code when run the example then got below issue

I have Python to 3.6 and pip version 9.0.1

command : python3.6 hello.py

Accepting connections on http://0.0.0.0:8080 Exception in callback UVTransport._call_connection_made handle: Traceback (most recent call last): File "uvloop/cbhandles.pyx", line 52, in uvloop.loop.Handle._run File "uvloop/handles/tcp.pyx", line 149, in uvloop.loop.TCPTransport._call_connection_made File "uvloop/handles/basetransport.pyx", line 140, in uvloop.loop.UVBaseTransport._call_connection_made File "uvloop/handles/basetransport.pyx", line 137, in uvloop.loop.UVBaseTransport._call_connection_made SystemError: NULL result without error in PyObject_Call

Please let me know where I change the configuration to work on it. I new to Python.

I really didn't understand what is causing the issue here. I have initialised producer like below. But when we call the request is failing. But the same thing if we execute in terminal or same structured code in Sanic is working fine.

Any ideas or suggestions to fix this?

# General Settings
import json

# Web Server specific imports
from japronto import Application
from json import JSONDecodeError
from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=["35.154.159.4:9092", "35.154.159.4:9093", "35.154.159.4:9094"], retries=5,value_serializer=lambda m: json.dumps(m).encode('ascii'))

def visuG(request):
	print(producer.config)
	print(producer)
	jstore = request.json
	print(jstore)	
	jevents = json.loads(jstore['e'])
	print(jevents)
	raw_data = {'topic': 'vnk-desd', 'routes': 'clst/desd', 'messages': jevents}
	f = producer.send("vnk-raw", raw_data)
	print(f)
	r = f.get(timeout=1)
	return request.Response(code=200,json=r)


app = Application()


# The Router instance lets you register your handlers and execute
# them depending on the url path and methods
r = app.router
r.add_route('/user-activity-poc', visuG, methods=["POST"])
r.add_route('/spcb', visuG, methods=["POST"])

# Finally start our server and handle requests until termination is
# requested. Enabling debug lets you see request logs and stack traces.
app.run(debug=True)

Error

Traceback (most recent call last):
  File "jap_server.py", line 22, in visuG
    r = f.get(timeout=1)
  File "/usr/local/lib/python3.6/site-packages/kafka/producer/future.py", line 60, in get
    "Timeout after waiting for %s secs." % timeout)
kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 1 secs.

I don't think it is because of timeout as I tried it with 10 seconds. It didn't work. Any ideas it is failing ?

I apologize if this is too noobie of a question, but could someone write an example of how to use templating with Japronto? I'm used to Flask with built-in templating support and I don't know how to get started without it.

My app structure (simplified):

app/
   templates/
   __init__.py
manage.py

app/__init__.py

from japronto import Application
from motor.motor_asyncio

client = motor.motor_asyncio.AsyncIOMotorClient()
db = client.mydb

async def index(request):
    result = await db.find_one()
    print(result)
    return request.Response(text=str(result), mime_type='text/html')

def create_app():
   app = Application()
   app.router.add_route('/', index)

manage.py

from app import create_app

if __name__ == '__main__':
   app = create_app()
   app.run(debug=True)

When I ran it, I got an exception:

RuntimeError: Task <Task pending coro=<pkg() running at  .../app/__init__.py:64> cb=[Pipeline._task_done()]> got Future <Future pending cb=[_chain_future.<locals>._call_check_cancel() at /miniconda/envs/flecom/lib/python3.6/asyncio/futures.py:407]> attached to a different loop

I suspect putting client = motor.motor_asyncio.AsyncIOMotorClient() inside index would work, but that would create new connections for every request. Reusing connection would be more preferable.

I was testing a server using Japronto in an Ubuntu-14.04 64bit Virtualbox VM when i came across this error:

Warning: Host CPU doesn't support SSE 4.2, selecting slower implementation Accepting connections on http://0.0.0.0:80 protocol.pause_writing() failed protocol: <cprotocol.Protocol object at 0x240f7f0> transport: <TCPTransport closed=False reading=True 0x233ac38> Traceback (most recent call last): File "uvloop/handles/basetransport.pyx", line 92, in uvloop.loop.UVBaseTransport._maybe_pause_protocol (uvloop/loop.c:64797) AttributeError: 'cprotocol.Protocol' object has no attribute 'pause_writing' protocol.resume_writing() failed protocol: <cprotocol.Protocol object at 0x240f7f0> transport: <TCPTransport closed=False reading=True 0x233ac38> Traceback (most recent call last): File "uvloop/handles/basetransport.pyx", line 108, in uvloop.loop.UVBaseTransport._maybe_resume_protocol (uvloop/loop.c:65168) AttributeError: 'cprotocol.Protocol' object has no attribute 'resume_writing'

here is the source code that caused the error. It happens every time i load the page "/register"

from base64 import b64encode
from datetime import datetime
from japronto import Application, RouteNotFoundException

#***Variables***#
with open("images/img.jpg", "rb") as f: imgdata = b64encode(f.read()).decode("utf-8")
basehtml = """
<!DOCTYPE html>
<html>
<head>
    <title>Registration</title>
    <style>
        html {{
            background: url("data:image/png;base64,%s") no-repeat center center fixed;
            -webkit-background-size: cover;
            -moz-background-size: cover;
            -o-background-size: cover;
            background-size: cover;
        }}
        .center {{
            width: 310px;
            height: 300px;
            position: absolute;
            top:0;
            bottom: 0;
            left: 0;
            right: 0;
            margin: auto;
        }}
    </style>
</head>
<body>
<form id="register" method="POST" autocomplete="off">
    <div class="center">
        <div id="formobject" style="width:310px">
            <h3 align="center" style="color:rgb(255, 255, 255)">Registration</h3>
            <input name="firstname" required="required" pattern="[A-Za-z0-9]{{1,20}}" type="text" style="width:300px" placeholder="first-name">
            <br>
            <input name="lastname" required="required" pattern="[A-Za-z0-9]{{1,20}}" type="text" style="width:300px" placeholder="last-name">
            <br>
            <input name="email" required="required" pattern="[^@]+@[^@]+\.[a-zA-Z]{{2,6}}" type="text" style="width:300px" placeholder="[email protected]">
            <br><br>
            <button style="float:right">Submit</button>
        </div>
        <div id="noticeobject">{notice}</div>
    </div>
</form>
</body>
</html>
"""%(imgdata)

#***Functions***#
def page(request):
    html = basehtml.format(notice="")
    return request.Response(text=html, headers=server_headers(), mime_type="text/html")

def server_headers():
    return {
        "Server": "nginx",
        "Date": datetime.now().strftime("%a, %d %Y %H:%M:%S GMT"),
        "Last Modified": "Sun, 19 2017 09:00:01 GMT",
        "Accept Ranges": "bytes",
    }

def handle_404(request, exception):
    """Handles any 404 errors within Server"""
    print("[404] FROM: %s, TO: %s"%(request.remote_addr,request.path))
    """Handles 404 Requests"""
    html="""<html>
<head><title>404 Not Found</title></head>
<body bgcolor="white">
<center><h1>404 Not Found</h1></center>
<hr><center>nginx</center>
</body>
</html>
"""
    return request.Response(text=html, headers=server_headers(), code=404, mime_type="text/html")

#***Classes***#
class NewApp(Application):
    """Used to modify the error handler to provide a better response on server and client"""
    def protocol_error_handler(self, error):
        """System Error Handler"""
        if error == "malformed_headers": error+=" (Possible Port Scan or Attack)"
        print("System Error: %s"%(error))
        error = error.encode('utf-8')
        response = """<html>
<head><title>400 Bad Request</title></head>
<body bgcolor="white">
<center><h1>400 Bad Request</h1></center>
<hr><center>nginx</center>
</body>
</html>
"""
        return response.encode('utf-8')

#***Start***#
app = NewApp()
app.router.add_route('/register', page)
app.add_error_handler(RouteNotFoundException, handle_404)
app.run(port=80,debug=False)

This error does not occur when i remove the base64 encoded image from the html, is uvloop having trouble writing all the data at once?

My server works perfectly with JSON and text requests, but when i try to receive files I have an error. Python Traceback ->

File "template.py", line 85, in uploadFile file.save(f) AttributeError: 'File' object has no attribute 'save'

The code I'm using : -> def uploadFile(request): file = request.files["data"] f = open("/Users/pewdepiebestthantseries/Documents/Japronto/uploader/" + request.files["data"].name, 'wb', 10000) file.save(f) print("All right") return request.Response(text="'Completed!'")

The content of data is an array that contains an image.

A simple request -> curl -i -X POST -H "Content-Type: multipart/form-data" -F "data=@/Users/pewdepiebestthantseries/Downloads/lasagna.png" http://IP:PORT/file

HEELP

MacBook-Pro:test rilut$ pip3 install  uvloop==0.9.1
Collecting uvloop==0.9.1
  Using cached uvloop-0.9.1-cp36-cp36m-macosx_10_11_x86_64.whl
Installing collected packages: uvloop
  Found existing installation: uvloop 0.8.1
    Uninstalling uvloop-0.8.1:
      Successfully uninstalled uvloop-0.8.1
Successfully installed uvloop-0.9.1

MacBook-Pro:test rilut$ python3 japro.py
Accepting connections on http://0.0.0.0:8080
Exception in callback UVTransport._call_connection_made
handle: <Handle UVTransport._call_connection_made>
Traceback (most recent call last):
  File "uvloop/cbhandles.pyx", line 52, in uvloop.loop.Handle._run
  File "uvloop/handles/tcp.pyx", line 149, in uvloop.loop.TCPTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 156, in uvloop.loop.UVBaseTransport._call_connection_made
  File "uvloop/handles/basetransport.pyx", line 153, in uvloop.loop.UVBaseTransport._call_connection_made
SystemError: NULL result without error in PyObject_Call

MacBook-Pro:test rilut$ pip3 install  uvloop==0.8.1
Collecting uvloop==0.8.1
  Downloading uvloop-0.8.1-cp36-cp36m-macosx_10_11_x86_64.whl (1.2MB)
    100% |████████████████████████████████| 1.2MB 748kB/s
Installing collected packages: uvloop
  Found existing installation: uvloop 0.9.1
    Uninstalling uvloop-0.9.1:
      Successfully uninstalled uvloop-0.9.1
Successfully installed uvloop-0.8.1

MacBook-Pro:test rilut$ python3 japro.py
Accepting connections on http://0.0.0.0:8080

Bumps sanic from 0.2.0 to 20.12.7.

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

I have tried this way - python3 setup.py install

Error Message: /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:14:2: error: this header is for x86 only #error this header is for x86 only ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:286:5: error: invalid output constraint '=a' in asm __cpuid(__leaf, __eax, __ebx, __ecx, __edx); ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:251:11: note: expanded from macro '__cpuid' : "=a"(__eax), "=r" (__ebx), "=c"(__ecx), "=d"(__edx) \ ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:301:5: error: invalid output constraint '=a' in asm __cpuid(__leaf, *__eax, *__ebx, *__ecx, *__edx); ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:251:11: note: expanded from macro '__cpuid' : "=a"(__eax), "=r" (__ebx), "=c"(__ecx), "=d"(__edx) \ ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:315:5: error: invalid output constraint '=a' in asm __cpuid_count(__leaf, __subleaf, *__eax, *__ebx, *__ecx, *__edx); ^ /Library/Developer/CommandLineTools/usr/lib/clang/13.0.0/include/cpuid.h:258:11: note: expanded from macro '__cpuid_count' : "=a"(__eax), "=r" (__ebx), "=c"(__ecx), "=d"(__edx) \ ^ 4 errors generated. error: command 'clang' failed with exit status 1

How can i fix this??

Code snippet

Parser_feed(Parser* self, PyObject *args)
{
     ........
     if((size_t)data_len > self->buffer_capacity - (self->buffer_end - self->buffer_start)) {
            self->buffer_capacity = MAX(self->buffer_capacity * 2, self->buffer_end - self->buffer_start + data_len);
            if(self->buffer == self->inline_buffer) {
                   self->buffer = malloc(self->buffer_capacity);    --------> may return a NULL pointer
                   memcpy(self->buffer + self->buffer_start, self->inline_buffer + self->buffer_start,
                                  self->buffer_end - self->buffer_start);
    } 
    ........
}

Description

Function: Parser_feed File: cparser.c Call-path: feed (Python) -> Parser_feed -> memcpy WarningType: Invalid write. Our analysis tool reported a warning on potential write at an invalid address. As the buffer_capacity may depend on external inputs, hence it is possible that malloc-fail happens. Return value validation is necessary at this point. Also seen in Details

I thank your team The latest version is a year old and I'm surprised by the performance of Japronto, but are you not updating it and also is it possible to communicate with neo4j ? japronto and neo4j are best .

Otherwise, the following code is required:

class Application(Application):
    @property
    def _log_request(self):
        return False

    @_log_request.setter
    def _log_request(self, value):
        pass
    

app = Application(log_request=False)