1.waiter_addr_info.py: hanler_new_tx 最后存入kafka topic的数据格式如下: . simple_hanler 下的 handelr_cache.py
处理new tx块数据，解析增量,统计出来addr_info表:
multi_address 用于记录多签编码地址到原地址的映射,统计出multi_address表import hashlib
import binascii
# 多签地址合并加密
def btc_multsig_encrypt(addresses):
addr_str='_'.join(addresses)
return hashlib.md5(addr_str.encode('utf-8')).hexdigest()
# 循环冗余校验
def crc32_address(address, cnt):
"""
将地址转成crc32的值，并按照cnt取余，用于将redis的key均匀分配到各个桶
:param address: 地址
:param cnt: 桶的总数
:return: 桶的名字
"""
return binascii.crc32(address.encode('utf-8')) % cnt
最后
以上就是调皮煎饼最近收集整理的关于BTC学习知识点总结2的全部内容，更多相关BTC学习知识点总结2内容请搜索靠谱客的其他文章。
发表评论 取消回复