1.在python中,pip install kazoo 和 pip install zc-zookeeper-static

2.zk创建节点 在test_base.py中

import sys
import time
from kazoo.client import KazooClientzk=KazooClient(hosts='127.0.0.1:2181')
zk.start()#Creating Nodes
# Ensure a path, create if necessary
zk.ensure_path("/bl/jhy")# Create a node with data
zk.create("/bl/jhy/node", b"")
zk.create("/bl/jhy/node/a", b"A")

3.touch bl.data文件,把黑名单都写入这个文件中,
然后创建test_black.py ,读取黑名单中的数据往zk节点中写入黑名单数据

import sys
import time
from kazoo.client import KazooClientblock_list = []
with open("bl.data") as fd:for line in fd:block_list.append(line.strip())zk=KazooClient(hosts='127.0.0.1:2181')
zk.start()# Print the version of a node and its data
zk.set("/bl/jhy/node",'\n'.join(block_list))
  1. 在zookeeper下查看。黑名单数据
./bin/zkCli.sh
get /bl/jhy/node

往zookeeper中写入黑名单相关推荐

  1. Kafka在ZooKeeper中的应用

    以下是kafka在zookeep中的详细存储结构图: 1.Broker注册 Kafka是一个分布式的消息系统.Kafka 集群包含一个或多个服务器,服务器节点称为broker.虽然Broker是分布式 ...

  2. zookeeper中展示所有节点_Zookeeper数据结构与监听机制

    ZooKeeper数据模型Znode 在ZooKeeper中,数据信息被保存在⼀个数据节点上,这些节点被称为znode.ZNode 是 Zookeeper 中最小数据单位,在 ZNode 下⾯又可以再 ...

  3. SparkStreaming 实现广告计费系统中在线黑名单过滤实战

    本博文内容主要包括以下内容: 1.在线黑名单过滤实现解析 2.SparkStreaming实现在线黑名单过滤 一.在线黑名单过滤实现解析: 流式处理是现代数据处理的主流,各种电子商务网站,搜索引擎等网 ...

  4. Zabbix监控之从zookeeper中获取Kafka消费进度和lag

    Kafka在0.9之前,消费进度是存放在zookeeper中,在0.9及之后的版本,kafka自身提供了存放消费进度的功能.从kafka中获取消费进度请查看我另一片文章 传送门 这篇文章是转载自htt ...

  5. java向mysql写入数据慢_通过java代码往mysql数据库中写入日期相关数据少13个小时...

    通过show variables like '%time_zone%'; 查看时区: CST 时区 名为 CST 的时区是一个很混乱的时区,有四种含义: 美国中部时间 Central Standard ...

  6. zookeeper中dubboo节点过多导致dubbo-admin启动失败排查

    1.起因 新需求开发了一个新接口,在联调环境正常注册,到了测试环境,调用方找不到对应接口: 通过dubbo-admin,查看服务注册情况,发现以下情况:   1.新接口 和 其他旧接口  均未在dub ...

  7. 33. 使用fread()/fwrite()往文件中写入结构体,从文件中读出结构体

    1 //读写结构体 2 #include <stdio.h> 3 typedef struct student 4 { 5 int num; 6 char name[30]; 7 char ...

  8. OpenCV实现在图像中写入汉字

    由于OpenCV自带的cvInitFont和cvPutText函数不支持向图像中写入中文,参考http://www.opencv.org.cn/forum/viewtopic.php?t=2083 中 ...

  9. php向页面中添加数据_PHP创建文件,并向文件中写入数据,覆盖,追加的实现代码...

    创建文件我们用到函数 fopen ( string filename, string mode ) 参数filename为创建文件名 参数mode为以什么方式打开文件filename 其中mode可能 ...

最新文章

  1. IntelliJ IDEA WEB项目的部署配置
  2. Git之常见零碎问题的原因分析和解决方案
  3. 解决No enclosing instance of type * is accessible
  4. LiveVideoStackCon深圳 - VR/AR基础技术更成熟
  5. Integer 中的缓存类IntegerCache
  6. P4306-[JSOI2010]连通数【bitset】
  7. python turtle绕原点旋转_「加德老师与小朋友们的编程之旅」Python海龟作图(上)
  8. 【计算机组成原理】运算器组成实验
  9. 数字核心 驱动转型:SAP S/4HANA 数字化转型论坛 - 杭州站 即刻报名
  10. 生意参谋爬虫难点一 ——十六进制数据解密
  11. c语言编程被当作病毒,c语言编写病毒
  12. 打印 条码 CodeSoft JsBarCode
  13. 免费好用的OCR文字识别软件推荐
  14. 如何管理项目成本:工时管理
  15. python制作动态时钟_python实现简易动态时钟
  16. 【云锁·nginx自编译web防护教程】
  17. html写前端手机页面,前端编写手机兼容页面(简易方式)
  18. VUE v-modle 实现 |||| uniapp 父子组件实现 v-modle
  19. 【Cherno的OpenGL视频】Vertex buffers and drawing a triangle in OpenGL
  20. outlook2010签名设置 怎麼用html 设置名片,windows10系统下Outlook2010如何设置邮箱签名...

热门文章

  1. 5月6阴阳师服务器维护,阴阳师5月6日维护更新公告 御魂加成开放购买
  2. Java基础函数式编程
  3. 晨兴资本程宇:新一波技术革命前夜,谁的机会更大?
  4. 网络爬虫结合搜索引擎
  5. 银行卡信息查询,信息安全获取
  6. 家装老总“傍”邓亚萍找到第一桶金
  7. 【bzoj1770/Usaco2009 Nov】lights 燈——折半搜索
  8. 鸿蒙os四月,4月鸿蒙OS系统,支持升级名单,麒麟710之后皆可升级
  9. php微信小程序毕业设计 php家政服务预约小程序毕业设计开题报告功能参考
  10. iphone私密相册计算机,‎App Store 上的“私密相册(计算器版)-私密照片视频加密保护”...