很多情况下，需要从不同的数据源中提取数据，并将数据格式进行转换，定义不同的流程，传输到对应的系统中

需求较为简单的情况下，可以通过自己写代码实现，但在数据流比较复杂后，整个流程难以维护，扩展性很差

这时候就需要引入像 NiFi、StreamSets 这类的 DFM(Data Flow Management) 数据流处理平台，这篇文章主要介绍在 NiFi 中定义一个简单的数据流

明天就是 2019 了，简单总结一下 2018 年买过的电子产品。

前几周花了 50 个小时把 刺客信条·起源 三条主线通关了，很多云玩家认为奥德赛只是起源换了一个皮肤，但是相信真正玩过奥德赛的人不会那么认为，起源是刺客信条 ARPG 和开放世界的初次尝试，而奥德赛增强 ARPG 元素则代表育碧在 ARPG 和开放世界下功夫的决心。

大约半个月前 AirPods 右耳没有声音，无论如何重连，重置，通过 Find My AirPods 播放声音都没用，但是右耳手势能够正常使用，确定耳机故障，于是准备预约 GeniusBar 维修，但是由于附近的 Apple Store 实在太忙了，预约得到下周，然后我为了省事直接走的 京东 售后，预约隔天取件。

由于在外出差，无法提供包装盒以及原装配件，快递小哥上门时候没办法扫描条形码完成取件流程，和快递小哥商量，耳机先给他带回快递站，然后我去问客服要条形码发给他走流程。

第二天，我的 AirPods 开始前往 上海3C备件库 ，并于 16 号到达这个仓库，然后就没有任何消息了。

没有 AirPods 的我仿佛没有了灵魂，每隔几天就骚扰一下京东 网页客服 希望能快点维修，但是网页客服 总是用 周期为15-30天左右 的说明来搪塞我。

直到前天，我的显示器屏幕碎了，也走了售后的流程，同样是寄往 上海3C备件库 ，但是一天内就有人联系我，说明商品的拆包检测情况，我就感觉不对劲了，于是昨晚我联系了京东的 电话客服 ，没想到 电话客服直接就说我寄的东西与原商品不符合，于是被拒收了。。。但是我半个月却没有收到任何信息，电话客服说隔天会有专员联系我处理此事。

今天中午的时候，京东售后专员联系了我，描述了具体的情况，说他们收到了 空包 ，我向他解释了上门取件的一些细节后他说可以进行现金赔付，但需要一到两天的时间走流程。

这件事情到此算是结束了，对于处理结果还是相对满意的，但是仍然有以下几个疑问。

• 京东网页客服的权限是否没有电话客服大，为什么电话客服能够准确的解决我的问题
• 京东售后取件 -> 维修的流程是否有漏洞，为什么会出现这种情况

作为京东的钻石+Plus会员多年，一直对京东的时效性和售后服务很满意，但最近除了这件事情之外，还有好几次 京准达 快递没有准时送达，哎，希望京东继续努力吧。

WireGuard ®是一种非常简单而现代，快捷的VPN，利用最先进的加密技术。它比IPSec 更快，更简单，更精简，更有用。它比OpenVPN更高效。WireGuard设计为通用VPN，适用于多种不同情况。它是跨平台的，可大规模部署。它已经被认为是业内最安全，最易于使用，最简单的VPN解决方案。

由于长期出差，又想玩 刺客信条·奥德赛，所以这几天研究了一下 互联网串流的解决方案

最后选择了 moonlight + NVIDIA Shield 的方案

moonlight 是一个跨平台并且支持 NVIDIA GAMESTREAM 协议的客户端

moonlight 支持最高 120 FPS、4K 分辨率、Xbox/PS4 等控制器

互联网串流参考 https://github.com/moonlight-stream/moonlight-docs/wiki/Setup-Guide

通过控制台获取 TOKEN ，注意请求参数中的 TOKEN 是 用户 ID + TOKEN 组合

dnspod 文档

$ cat /etc/ddns/ddns.sh
IP=$(/sbin/ifconfig pppoe-wan| grep 'inet addr' | cut -d: -f2 | awk '{print $1}') # 这里 pppoe-wan 指的是公网地址的接口

/usr/bin/curl -X POST https://dnsapi.cn/Record.Ddns -d "login_token=${ACCOUNT_ID},${TOKEN}&record_line_id=0&sub_domain=home&value=${IP}"

$ cat /etc/crontabs/root
*****
*/1 * * * * /etc/ddns/ddns.sh # 如果1小时之内，提交了超过5次没有任何变动的记录修改请求，该记录会被系统锁定1小时

今天想给家里路由器 (XiaoMi R3D) 做个端口映射给同事演示做的东西，但是发现通过网页设置路由器端口映射直接返回 500 错误，查了下日志也看到什么错误，然后查看了一下相关代码，并通过 lua 交互式客户端调试了一下

> do
    local pf = require("xiaoqiang.module.XQPortForward")
    pf.setPortForward('test', '192.168.231.204', 6800, 8000, "tcp")
end>> >> >> >> >> >>
/usr/lib/lua/xiaoqiang/module/XQPortForward.lua:93: attempt to compare nil with number
stack traceback:
        [C]: in function 'foreach'
        /usr/lib/lua/xiaoqiang/module/XQPortForward.lua:104: in function '_portConflictCheck'
        /usr/lib/lua/xiaoqiang/module/XQPortForward.lua:181: in function 'setPortForward'
        stdin:6: in main chunk
        [C]: ?

近日测试 openstack 作为 kubernetes 的基础设施平台为 kubernetes 提供基础服务(storage, loadbalancer)

目标：

• 为 kubernetes 提供 cinder 作为持久卷
• 通过 openstack 的 LBAAS v2 为 kubernetes 提供 LoadBalancer

集群架构

中文解释 Kubernetes Handbook

来源

I. Codebase

One codebase tracked in revision control, many deploys

II. Dependencies

Explicitly declare and isolate dependencies

III. Config

Store config in the environment

IV. Backing services

Treat backing services as attached resources

V. Build, release, run

Strictly separate build and run stages

VI. Processes

Execute the app as one or more stateless processes

VII. Port binding

Export services via port binding

VIII. Concurrency

Scale out via the process model

IX. Disposability

Maximize robustness with fast startup and graceful shutdown

X. Dev/prod parity

Keep development, staging, and production as similar as possible

XI. Logs

Treat logs as event streams

XII. Admin processes

Run admin/management tasks as one-off processes