minhoryang/README.md

## README.md

      
    Raw
  

              README.md
            
          
    gunicorn -w4 --log-level=DEBUG --timeout=5 app:app

  
## app.py
import signal

from flask import Flask, jsonify

from async_land import call_async_as_sync


app = Flask(__name__)


@app.route('/')
def hello():
    return 'okay'


@app.route('/call')
def calling():
    return jsonify(call_async_as_sync())


if __name__ == "__main__":
    app.serve(debug=True)
else:
    # SIGINFO for debug.
    def info(*args):
        import os
        print(os.getpid(), args)

    signal.signal(signal.SIGINFO, info)

## async_land.py
import asyncio
import os

from aiohttp_requests import requests


PID = os.getpid()


async def _call(idx=0, tid=0):
    print('call', PID, tid, idx)
    # XXX: Target Async Func.
    response = await requests.get('https://httpbin.org/anything')  # TODO: more random wait would be dramatic.
    json = await response.json()
    print('done', PID, tid, idx)
    return json


async def _multiple_calls(loop):
    return await asyncio.gather(
            _call(0, loop._thread_id),
            _call(1, loop._thread_id),
            _call(2, loop._thread_id),
    )


def call_async_as_sync():
    loop = asyncio.get_event_loop()
    ret = loop.run_until_complete(
            _multiple_calls(loop)  # FIXME: timeout?
    )
    # XXX: no need to close the loop
    # print(loop.is_running())
    # loop.close()
    return ret


if __name__ == "__main__":
    print('s')
    print(call_async_as_sync())
    print('e')

## requirements.txt
# python >= 3.7
aiohttp-requests
flask
gunicorn
	import signal

	from flask import Flask, jsonify

	from async_land import call_async_as_sync


	app = Flask(__name__)


	@app.route('/')
	def hello():
	return 'okay'


	@app.route('/call')
	def calling():
	return jsonify(call_async_as_sync())


	if __name__ == "__main__":
	app.serve(debug=True)
	else:
	# SIGINFO for debug.
	def info(*args):
	import os
	print(os.getpid(), args)

	signal.signal(signal.SIGINFO, info)
	import asyncio
	import os

	from aiohttp_requests import requests


	PID = os.getpid()


	async def _call(idx=0, tid=0):
	print('call', PID, tid, idx)
	# XXX: Target Async Func.
	response = await requests.get('https://httpbin.org/anything') # TODO: more random wait would be dramatic.
	json = await response.json()
	print('done', PID, tid, idx)
	return json


	async def _multiple_calls(loop):
	return await asyncio.gather(
	_call(0, loop._thread_id),
	_call(1, loop._thread_id),
	_call(2, loop._thread_id),
	)


	def call_async_as_sync():
	loop = asyncio.get_event_loop()
	ret = loop.run_until_complete(
	_multiple_calls(loop) # FIXME: timeout?
	)
	# XXX: no need to close the loop
	# print(loop.is_running())
	# loop.close()
	return ret


	if __name__ == "__main__":
	print('s')
	print(call_async_as_sync())
	print('e')