合法的pay group里所有worker的比例是一样的，即 wage1/wage2 = quality1/quality2 推出 wage1/quality1 = wage2/quality2。 这就好办了，定义 ratio_i = wage_i/quality_i。对于一个group，ratio ...
分类：
其他好文 时间：
2019-09-08 12:26:35
阅读次数：
73
rke删除节点：修改cluster.yal将需要删除的节点配置删除，然后运行[root@cnvs-kubm-101-103rke]#morecluster.ymlnodes:-address:172.20.101.103user:ptmindrole:[controlplane,worker,etcd]-address:172.20.101.104user:ptmindrole:[controlp
分类：
其他好文 时间：
2019-09-05 16:41:00
阅读次数：
211
``` # 线程隔离 from werkzeug.local import LocalStack import threading # 首先实例化 my_stack = LocalStack() my_stack.push(1) # 主线程入栈 def worker(): print("in wor... ...
分类：
编程语言 时间：
2019-09-03 09:59:39
阅读次数：
120
三、如何保证消息的顺序性 拆分多个queue，每个queue一个consumer，就是多一些queue而已，确实是麻烦点；或者就一个queue但是对应一个consumer，然后这个consumer内部用内存队列做排队，然后分发给底层不同的worker来处理 写入一个partition中的数据一定是有 ...
分类：
其他好文 时间：
2019-09-03 09:14:07
阅读次数：
117
nginx反向代理配置文件 nginx.conf proxy_default.conf vhost/*.conf upstream/*.conf cache/*.conf nginx.conf 配置 user www; worker_processes 2; pid /var/run/nginx.p ...
分类：
其他好文 时间：
2019-09-02 17:18:33
阅读次数：
386
ngx_lua模块的原理： 1、每个worker（工作进程）创建一个Lua VM，worker内所有协程共享VM；2、将Nginx I/O原语封装后注入 Lua VM，允许Lua代码直接访问；3、每个外部请求都由一个Lua协程处理，协程之间数据隔离；4、Lua代码调用I/O操作等异步接口时，会挂起当 ...
分类：
其他好文 时间：
2019-09-02 12:12:31
阅读次数：
80
openresty开发系列26--openresty中使用redis模块在一些高并发的场景中，我们常常会用到缓存技术，现在我们常用的分布式缓存redis是最知名的，操作redis，我们需要引入redis模块 require "resty.redis"；我们现在做个可以操作redis进行赋值，读值的案 ...
分类：
其他好文 时间：
2019-08-30 14:38:53
阅读次数：
117
一、Spark运行流程 1、构建Spark Application的运行环境（启动SparkContext），SparkContext向资源管理器（可以是Standalone、Mesos或YARN）注册并申请运行Executor资源； 2、资源管理器分配Executor资源并启动Standalone ...
分类：
其他好文 时间：
2019-08-29 20:01:04
阅读次数：
65
1.什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 Celery架构： Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（task res... ...
分类：
其他好文 时间：
2019-08-29 15:55:11
阅读次数：
146
工程结构说明： __init__.py：实例化celery，并加载配置模块 celeryconfig.py：配置模块 task1：任务1，实现加法 task2：任务2，实现乘法 app.py：应用，任务生产者 1、__init__.py：实例化celery，并加载配置模块 ...
分类：
编程语言 时间：
2019-08-28 10:56:06
阅读次数：
257
