摘要： Rabbitmq 集群配置： 我这用普通用户启动后，在本用户的目录下边有个：.erlang.cookie 文件，我用rabbitmq用户启动就是在/home/rabbitmq目录下边有这个文件，如果rpm包安装的，这个文件目录在：/var/lib/rabbitmq 目录下边。 这点，如果重启使用RO 阅读全文

摘要： 消费者的请求头 生产者设置请求头 由于消费者那里，@Payload是接受的消息体，使用了@Header注解，需要请求头，生产者这边就要设置请求头，然后rabbitTemplate再调用convertAndSend方法发送，如下代码： 这是RabbitTemplate中的converAndSend（e 阅读全文

摘要： from pyspark import SparkContext, SparkConf from pyspark.sql import SparkSession def create_sc(): sc_conf = SparkConf() sc_conf.setMaster('spark://mas 阅读全文

摘要： channel.basicReject(deliveryTag, true); basic.reject方法拒绝deliveryTag对应的消息，第二个参数是否requeue，true则重新入队列，否则丢弃或者进入死信队列。 该方法reject后，该消费者还是会消费到该条被reject的消息。 ch 阅读全文

摘要： AUC（Area Under Curve）被定义为ROC曲线下与坐标轴围成的面积，显然这个面积的数值不会大于1。又由于ROC曲线一般都处于y=x这条直线的上方，所以AUC的取值范围在0.5和1之间。AUC越接近1.0，检测方法真实性越高;等于0.5时，则真实性最低，无应用价值。 AUC（Area U 阅读全文

摘要： pediawiki对X11的定义如下： The X window system (commonly X Window System or X11, based on its current major version being 11) is a computer software system a 阅读全文

摘要： -x禁止x11转发 -X允许x11转发 命令如下： ssh -X username@ipaddress A机器通过ssh登录到B机器，把B机器运行的某界面程序放到A机器上！ 如下例子： 执行assistant后，就可以调用101机器上的assistant程序显示到本机器的界面了! 如下图所示： 阅读全文

摘要： 以前转载过一篇别人的关于opendistro的文章，还好使用docker-compose 运行，很方便，所以自己也跑下 环境准备 docker-compose 文件 version: '3' services: odfe-node1: image: amazon/opendistro-for-ela 阅读全文

摘要： 一条消费成功被消费经历了生产者->MQ->消费者，因此在这三个步骤中都有可能造成消息丢失。 一 消息生产者没有把消息成功发送到MQ 1.1 事务机制 AMQP协议提供了事务机制，在投递消息时开启事务支持，如果消息投递失败，则回滚事务。 自定义事务管理器 @Configuration public c 阅读全文

摘要： addFile(path, recursive=False) 把文件分发到集群中每个worker节点，然后worker会把文件存放在临时目录下，spark的driver和executor可以通过pyspark.SparkFiles.get()方法来获取文件的路径，从而能够保证driver和每个wor 阅读全文