之前解决了：
【临时解决】Flask出错：NoRedisConnectionException Could not resolve a Redis connection
但是又遇到一个问题：
虽然可以执行schedule的任务，但是每次都是独立运行：
即新生成app：
17:48:01 default: runningfast.resources.BackgroundWorker.updateUserStatus() (8a254cb9-6797-40a7-b43a-ade4eecf5c52) <div–<—————————————————————————— DEBUG in app [./runningfast/app.py:104]: conn=Redis<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>, queue=<Queue u’default’>, pushConnResult=None <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in app [./runningfast/app.py:110]: app=<Flask ‘runningfast.app’>, server_port=21085, api=<flask_restful.Api object at 0x7f5a9431afd0>, redis_store=<flask_redis.FlaskRedis object at 0x7f5a95bda0d0>, db=<SQLAlchemy engine=’mysql://runningfast:Jiandao123@localhost/runningfast_dev’>, server_mode=staging, server_type=develop, rq=<flask_rq2.app.RQ object at 0x7f5a9432b450>, sockets=<flask_sockets.Sockets object at 0x7f5a9432b7d0> <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in app [./runningfast/app.py:131]: API_VERSION=1.0, API_URL_PREFIX=/runningfast/api/v1.0, OPEN_API_URL_PREFIX=/runningfast/api/v1.0/open <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in BackgroundWorker [./runningfast/resources/BackgroundWorker.py:92]: updateUserStatusJob=<Job 7f25f407-7f9b-420d-af81-31ba58e01786: runningfast.resources.BackgroundWorker.updateUserStatus()> <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in BackgroundWorker [./runningfast/resources/BackgroundWorker.py:37]: gOnlineUserIdList=[] <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in BackgroundWorker [./runningfast/resources/BackgroundWorker.py:40]: curDatetime=2016-11-06 17:48:02.000452 <div–<—————————————————————————— <div–<—————————————————————————— DEBUG in BackgroundWorker [./runningfast/resources/BackgroundWorker.py:77]: after remove offline: gOnlineUserIdList=[] <div–<—————————————————————————— 17:48:02 default: Job OK (8a254cb9-6797-40a7-b43a-ade4eecf5c52) 17:48:02 Result is kept for 500 seconds 17:48:02 17:48:02 *** Listening on default… |
从而导致：
无法获得之前flask的app内的全局变量gOnlineUserIdList的值
本来由于：
【规避解决】Flask中开了多个worker时如何使用全局变量
能保证只有一个Flask的app了，
所以想要去研究：
对于单个app内的全局变量的值
flask 如何保存全局变量
flask源码剖析之上下文全局变量 – zhuma的编程学习 – 博客频道 – CSDN.NET
Inside Flask – globals 全局变量（对象代理） – drop * – 博客园
结果发现上述已经是另外新生成app，不是单个app了
所以也不行。
所以现在无法解决：
多个Flask的app的情况下
如果保存全局变量值
如何在被调度的任务中，获取别处的，全局变量的值
难道不行，或许Celery能解决此问题吗？
flask access global variable
python – Are global variables thread safe in flask? – Stack Overflow
开发模式下的Flask是默认单进程，单线程的
生产环境下，（往往是）可以启动多进程和多线程的
app.run(threaded=True) or app.run(processes=10).
全局变量不是线程安全的，也不是进程安全的
-》应该用Flask之外的东西，去保存全局变量
-》比如数据库，Memcached，Redis
-》针对于单个User的话， 也可以考虑session
The Application Context — Flask Documentation (0.11)
Understanding Contexts in Flask
搜：
flask memcache save object
how to use flask-cache and memcached? – Stack Overflow
app.config[“CACHE_TYPE”]=“memcached” |
->说是：
直接用：
pip install pylibmc
可能不会正确安装匹配版本的
而要自己手动去指定安装对应的版本的：
libmemcached, pylibmc and python-dev
才可以？
Flask: how to store and retrieve a value bound to the request – Stack Overflow
flask.g只是针对于当前线程，当前request请求的
-》所以是线程安全的
-》其他线程是无法访问到的。。。
Flask-Cache — Flask-Cache 0.13 documentation
Caching — Flask Documentation (0.11)
python – How to pass complex objects across view functions/sessions in Flask – Stack Overflow
说是可以考虑：
Flask-Cache
但是也还是，不同线程，需要不同cache。。。
python – Cache one large object and read from cache fast for flask – Stack Overflow
-》Flask-Cache的SimpleCache内部是使用Werkzeug的cache，内部是调用pickle去把对应序列化为字符串的
-》但是我此处就是：
使用的是Flask-Sockets的Websocket，没法序列化啊。。。
【后记】
后来是通过：
【避开解决】Flask中开了多个worker时如何使用全局变量
而避开全局变量的方案，改用（redis+gevent去实现了）线程间通信，实现了：
gevent新建协程，把ws传递进去，待后续处理。
而用redis实现了pubsub系统：
别处有需要发送的消息，通过redis的publish
然后之前spwan的gevent协程中，会listen到对应的消息，然后调用实时的ws对象，去send消息。
转载请注明：在路上 » 【规避解决】Flask中对于单个app实例如何获取全局变量