摸爆

@monkeyWie 嗯嗯，真要项目搞，还是用一些开源包好点

感觉不需要写太多代码，直接用 channel 控制就好了
https://play.golang.org/p/JiD2EopqPkL

@MilletChili 说错了，redis 单线程

python 代码
# 加锁判断当前分片是否是最后一个
is_last_slice = False
if redis_helper.incr(sign) == slice_num:
is_last_slice = True

# with transaction.atomic():
# if SliceLock.objects.select_for_update().filter(sign=sign).first():
# if slice_num == len(os.listdir(temp_dir_path)):
# is_last_slice = True
# else:
# code, msg, data = (GlobalsCode.Err, 'sign 不存在', {'slice_name': slice_f.name})
# return retCORS(code, msg, data)

@h4de5 嗯，我之前说的不太清楚，应该是阿里云 oss 都是同步着传的，不会有并发的问题。我这边找到一个比较好的方案了，用 redis 的 incr，每保存一个分片就 incr 一下分片数，redis 单进程的不受并发影响，而且基于内存还快，比关系数据库开事务加锁快多了

@mlxj 文件 id 指的是啥？ MD5 值吗

@h4de5 阿里云 oss 的 sdk 都是安顺序一个一个分片传的，我开几个线程异步着传分片的情况呢

@MilletChili 我说的是最后几个分片哈

@mlxj 但请求是异步的啊，在判断<当前分片数==总数> 前，得加锁，不加的话，可能出现多个分片上传的请求中判断<当前分片数==总数>都成立或不成立的情况

@h4de5 好的，我去看一下

一般的查询，我都是叫前端去拼的，虽然我就是那个前端
start_num = int(request.GET.get('start_num') or 0) # 起始数
get_num = int(request.GET.get('get_num') or 10) # 需求数
filters = request.GET.get('filters') # 筛选条件
sorts = request.GET.get('sorts') # 排序条件
want_fileds = request.GET.get('want_fileds') # 指定需要的字段
is_distinct = request.GET.get('is_distinct') # 是否去重

qset = model.objects.using(using_database).all()

if filters:
# print('筛选条件：',filters)
qset = filterHelper(filters, qset)
if sorts:
# print('排序条件：',sorts)
qset = qset.order_by(*sorts.split(','))
if is_distinct == 'yes':
qset = qset.distinct()

all_num = qset.count() # 总个数
qset = qset[start_num: start_num + get_num]

if want_fileds:
data_list = createSerializers(model, want_fileds.split(','))(qset, many=True).data
else:
data_list = Ser_L(qset, many=True).data
data = {'all_num': all_num, 'data_list': data_list}

@haochih 感谢，我去看看

这应该是很多码农头疼的问题，我也是