首页
学习
活动
专区
圈层
工具
发布

振动温度入库:采集频率与数据清洗

后来把采集频率按物理量分开定,入库前加了一道清洗管道,才把这件事稳定下来。结论先放这里:振动和温度是两种节奏的数据,频率不该统一;清洗不是可选项,它的作用是把"能看"变成"能算"。...按统一频率采集,要么振动不够密、要么温度冗余十倍,两头都不合适。所以从网关侧就把两路数据分开配置。...二、入库前的四道清洗2.1 时间戳对齐与去重网关补传是常见的乱序来源:断网期间数据在本地缓存,恢复后一次性上传,时间戳是旧的,到达顺序是新的。...3.2 降采样与聚合入库清洗完的数据不直接全量入库。按设备、按分钟做一次聚合:均值、峰值、峰峰值、有效点数、异常点计数五个指标写进分钟表。原始点只在标记为异常时单独写入事件表。...之后所有网关统一走时间同步服务,误差控制在两百毫秒以内,入库时再记录一个上报时间,两个时间都留着,排查时能看出是采集延迟还是时钟偏差。4.3 传感器装错位置数据清洗得再干净,也救不了装错位置。

10800
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Kettle 加快数据入库速度

    在目标数据库连接选项中增加下列参数 useServerPrepStmts=false rewriteBatchedStatements=true useCompression=true useSSL=...rewriteBatchedStatements=true         常用于数据库连接为mysql。...默认情况下会无视executeBatch()语句,把批量执行的一组sql语句拆散,一条一条地发给MySQL数据库,批量插入实际上是单条插入,直接造成较低的性能。...useCompression=true         压缩数据传输,优化客户端和MySQL服务器之间的通信性能。 2....适当提高数据集大小         选择转换设置,在杂项中进行设置 size_rowset(记录集合里的记录数)。 3. 调整提交记录数大小         加大“表输出”步骤中的“提交记录数量”。

    1.8K30

    0604-6.1.0-如何使用StreamSets实时采集指定数据目录文件并写入库Kudu

    准备了两个数据文件共100条测试数据,数据的id是唯一的。 3.在StreamSets服务所在节点上创建一个/data1/tmp的数据目录,用于配置StreamSets的采集目录 ?...配置采集的数据目录及文件读取方式 ? 配置数据格式化方式,由于数据文件是以“,”分割因此选择CSV方式 ?...2.向/data1/tmp目录下拷贝一个准备好的数据文件 ? 可以看到Pipline监控数据的变化,采集到50条数据 ? user_info_kudu表数据显示有50条记录 ?...3.再次向/data1/tmp目录拷贝一个数据文件 ? 可以看到Pipline监控数据的变化,采集到100条数据 ? user_info_kudu表数据显示有100条记录 ? 入库的数据总条数 ?...5 总结 1.通过StreamSets可以方便的监听指定的数据目录进行数据采集,可以在Directory模块上配置文件的过滤规则、采集频率以及数据的格式化方式。

    2.1K20

    数据采集网关|工业数据采集网关

    数据采集网关|工业数据采集网关 随着数据量的不断增速,数据价值也逐步被许多公司所关注,尤其是偏重于业务型的企业,许多数据的发生,在未被挖掘整合的进程中通常被看作是一堆无效且占用资源的;但一旦被发掘,数据的价值将无可估计...近段时刻有幸参与负责了一个大数据项目,今日主要对收集体系做一次简单的复盘: 数据收集体系故名思意就是将数据从数据源收集到能够支撑大数据架构环境中,从而实现数据的收集以便后期对数据的二次加工树立数据仓库。...数据采集网关,物通博联数据采集网关相关产品: 1477559252.jpg 1480315233.jpg 一、业务流程整理 在业务流程整理的进程中,咱们先预设个场景,如: 当公司运营人员提出一个订单转化率的需求...,都需求获取哪些数据,获取到后要收集存储到哪个数据仓库的表中,终究被运用到。...数据源办理 数据源一般会分为许多种类型,因而,咱们需求树立数据源类型;如ORECAL、mysql、hive等。

    2.7K40

    数据采集器 数据采集终端

    TS511系列采集终端是集数据采集与2G/3G/4G/5G数据传输功能于一体的环保数据采集终端,完全符合《污染物在线自动监控(监测)系统数据传输标准》(HJ 212-2017) 和(HJ 212-2005...0.jpg 集视频图像监控、数据采集、数据存储、无线通信传输于一体 TS511环保数采仪,集视频图像监控、数据采集、数据存储、无线通信传输于一体;实现环保数据的采集、存储、显示、控制、报警及加密传输等综合功能...;智能采集上报实时采集数据、设备监控数据等数据信息;接口丰富,可扩展性强、功能强大,组网灵活。...污染物在线监控(监测)系统数据传输标准》通信协议,支持定制第三方上位机通信协议 支持多中心   适用于国控、省控、市控等各类环保在线监测系统,可选提供通信中心入库的方式接入第三方平台、可快速接入计讯智慧生态管理平台...多路采集数据存储空间自定义   支持多路采集数据存储空间自定义配置,每个采集数据的存储空间均支持自定义配置;传感器定制简单可配可选,Modbus RTU传感器不用软件定制可以兼容;海量空间,可在本机循环存储监测数据

    3.4K00

    秒级行情推送系统实战:从触发、采集到入库的端到端架构

    功能:保证行情数据在 秒级 被拉取。2. 采集层(Crawler)获取 股票/币价 最新行情。使用 代理IP(爬虫代理) 防止 API 请求被限流或封禁。3....三、关键代码详解(行情采集与推送)下面以 Python + requests + MySQL 为例,采集实时行情(模拟从交易所接口获取 BTC/USDT 最新价格),并写入数据库。..."]) return price except Exception as e: print("行情获取失败:", e) return None# ====== 数据入库函数...入库层 存储行情,用于历史分析。推送层 模拟实时推送,实际可用 WebSocket 广播。四、总结在行情业务中,秒级更新系统 的核心目标是:触发层:秒级驱动行情采集。...采集层:API + 代理IP 防止封禁。缓冲层:保障高并发稳定。入库层:保存历史+缓存实时数据。推送层:保证用户端 秒级可见行情。

    84410

    场景化 AI 回答采集任务,如何做队列调度和结果入库?

    本文围绕消费品牌 AI 回答监测这一典型场景,拆解从队列调度、并发采集、失败重试到分层存储的完整数据链路设计。...一、场景特征:采集任务的三个特殊约束消费品牌 AI 回答监测与普通数据采集有明显区别:任务量波动大:单次测评可能覆盖 7-8 个消费场景、5-6 个 AI 平台,每个组合再乘以 3-5 轮采样,任务数轻松破千...后续指标计算只统计 is_valid=1 的数据。七、场景化查询:数据如何被消费结构化入库后,按场景维度聚合变得简单。...通过 task_id 唯一约束 + 插入前检查,或使用幂等写入(INSERT IGNORE / ON DUPLICATE KEY UPDATE),避免同一条采集结果重复入库。3....消息队列负责调度与解耦,分层存储兼顾证据留存与指标提取,失败重试机制保证采集完整度,场景标签贯穿全链路让数据从采集那一刻就具备了业务语义。

    20710

    多平台 AI 回答采集任务如何做调度、归一化和结果入库?

    想从这些异构回答中统一提取“品牌是否被提及”“是否被推荐”等指标,后端需要解决三个核心问题:如何公平调度多平台任务、如何将不同格式的回答归一化、如何将归一化后的结果结构化入库。...本文将围绕这三个环节拆解完整的数据链路设计。一、为什么多平台采集需要归一化多平台采集与单平台采集的关键区别不在任务数量,而在输出的异构性。...二、整体数据链路链路分五个核心环节:公平调度、平台适配、原始留档、归一化转换、结构化入库。下文逐一展开。三、任务调度:跨平台公平采样多平台采集的首要原则是时间窗口一致性。...八、结语多平台 AI 回答采集的工程复杂度,本质上来自“异构输出”与“统一分析”之间的矛盾。...本文提出的归一化层设计,通过一个统一回答结构体和分平台适配器,将平台差异隔离在采集层,让下游的指标提取、一致性分析、跨平台对比等逻辑可以基于同一套数据结构运行。

    23110

    量化之tushare日线数据入库Mysql例子

    上篇文章写了DuckDB, 对于普通人来说, 可能用mysql数据保存量化数据更合适。 毕竟对于程序员来说, 大家一开始学的数据库基本是Mysql。选择自己最适合的更重要。...这里我写一个处理方案对日线数据入库的操作。 1、首先获取交易日日历(由于tushare需要2000积分, 这个接口暂时用akshare获取) 2、数据源, 最初我准备用miniqmt的。...3、我们看下tushare 的日线行情 接口:daily,可以通过数据工具调试和查看数据 数据说明:交易日每天15点~16点之间入库。...本接口是未复权行情,停牌期间不提供数据 调取说明:基础积分每分钟内可调取500次,每次6000条数据,一次请求相当于提取一个股票23年历史 描述:获取股票行情数据,或通过通用行情接口获取数据,包含了前后复权数据...name__ == '__main__': print("=" * 50) print(" 股票数据初始化系统启动") print("=" * 50) # 首次初始化历史数据

    1.1K10

    多品牌 AI 回答采集任务,如何做队列调度和对比结果入库?

    本文将围绕多品牌采集的任务编排、并发控制、对比结果生成和查询接口设计四个环节,拆解一条完整的数据链路。...一、多品牌采集的特殊约束单品牌采集和多品牌竞品对比,在工程上有三个关键差异:公平性要求:同一问题必须尽可能在同一时间窗口内向同一 AI 平台发送,避免因模型更新或联网数据变化导致对比基线不一致。...这三个约束决定了架构上需要分层设计:采集层负责公平调度,存储层负责对比聚合。二、整体数据链路链路分五个环节:任务编排、队列调度、并发控制、单品牌入库、对比聚合。下文逐一展开。...五、单品牌结果入库每个子任务完成后,提及率、推荐率、解释文本等指标写入单品牌结果表:CREATE TABLE brand_ai_performance ( id BIGINT AUTO_INCREMENT...九、结语多品牌 AI 回答采集与对比,本质上是将“竞品分析”从人工经验转化为系统化数据工程。

    24110

    数据采集来源有哪些?数据采集方式有哪些?数据采集怎么做?

    数据采集是指获取和收集数据的过程。数据采集来源多种多样,包括以下几个主要方面:1....数据采集方式有多种,根据数据来源和采集需求的不同,可以采用以下几种常见的数据采集方式:1. 手动输入:人工手动输入数据,适用于数据量较小、频次较低,且无法自动获取的情况。2....针对数据采集的具体步骤,可以按照以下几个阶段进行:1. 规划阶段:明确数据采集目标和需求,确定数据源和采集方式,制定采集计划和时间表。2....数据采集执行:根据采集计划和方法,执行数据采集操作,确保数据按照预定的频率和规模被获取。5....在进行数据采集时,需要明确采集目标、选择合适的数据源和采集方式,进行数据准备和清洗,进行有效的数据采集和质量控制,并确保数据的安全和隐私保护。

    10.1K10

    多平台 AI 回答采集任务如何做调度、归一化和结果入库?

    这不是一个脚本能解决的问题,而是一条需要认真设计的数据链路。本文将从云上任务调度、多平台采集适配、失败重试机制、回答归一化处理、结构化入库和一致性结果查询六个层面,完整拆解这条链路的工程实践思路。...任务管理层 → 采集执行层 → 归一化处理层 → 结构化入库层 → 查询分析层任务管理层:负责拆解测评任务、生成采集子任务、管理执行状态采集执行层:对接不同 AI 平台的问答接口,完成实际采样归一化处理层...:清洗原始回答、识别品牌实体、标准化数据结构结构化入库层:将归一化结果写入数据库,建立索引和关联关系查询分析层:提供面向业务的一致性查询能力下面逐层展开。...七、结构化入库:为查询而设计7.1 数据模型设计数据库设计需要同时满足写入效率和分析查询需求。...十、从工程链路到业务价值回到文章开头的问题:多平台 AI 回答采集怎么做调度、归一化和结果入库。

    32700

    数据采集:如何自动化采集数据?

    上一节中我们讲了如何对用户画像建模,而建模之前我们都要进行数据采集。数据采集是数据挖掘的基础,没有数据,挖掘也没有意义。...那么,从数据采集角度来说,都有哪些数据源呢?我将数据源分成了以下的四类。 ? 这四类数据源包括了:开放数据源、爬虫抓取、传感器和日志采集。它们各有特点。 开放数据源一般是针对行业的数据库。...火车采集器 火车采集器已经有13年历史了,是老牌的采集工具。它不仅可以做抓取工具,也可以做数据清洗、数据分析、数据挖掘和可视化等工作。...总结 数据采集是数据分析的关键,很多时候我们会想到Python网络爬虫,实际上数据采集的方法、渠道很广,有些可以直接使用开放的数据源,比如想获取比特币历史的价格及交易数据,可以直接从Kaggle上下载,...另一方面根据我们的需求,需要采集的数据也不同,比如交通行业,数据采集会和摄像头或者测速仪有关。对于运维人员,日志采集和分析则是关键。所以我们需要针对特定的业务场景,选择适合的采集工具。

    5.3K10
    领券