Dojo
话题
新佳
订阅
极道
元认知
元逻辑
元设计
元编程
元语言
后台计划调度任务作业教程
如何使用 Spring Boot Scheduler 计划和安排任务/作业?
有时我们会遇到这样一种情况,我们希望任务只在特定时间点执行或在特定时间间隔内重新执行。同时,我们的客户希望在特定时间以每小时、每天、每周、每月或什至其他方式执行功能。事实上,在所有这些类型的情况下,我们都会实施调度来相应地满足要求。例如,最流行的实现之一是在特定时间生成报告。
什么是数据沿袭、数据世系(data lineage)?
在 Back Market 的数据工程实习期间,我专注于为我们的内部数据消费者设计和集成数据沿袭平台。本文收集了我学到的关于如何快速识别不同类型的数据沿袭(数据世系data lineage)的关键经验。下面的文章将重点介绍实现。 可以将数据沿袭/数
如何使用 Kubernetes 和 GIT 部署 Airflow ?
Apache Airflow 给我留下了深刻的印象。引擎快如闪电,编写管道真的很容易。另一个很棒的功能是它与源代码控制同步。这样,我就知道在环境中执行了哪些内容。一个好的提示:拥有从主分支读取的暂存环境和从发布分支读取的生产环境很有用。
你应该使用 Apache Airflow 吗?
数据管道是任何公司数据基础架构中的关键组件。许多公司用来管理其数据提取和转换的一种框架是 Airflow。无论是 100% 使用 Airflow 及其各种运算符,还是使用 Airflow 编排其他组件,例如 Airbyte 和
基于Kubernetes的Spring Batch:大规模高效批处理
在这篇博文中,我介绍了批处理开发人员或架构师在大规模设计和运行批处理应用程序时可能面临的一些挑战,并展示了 Spring Batch、Spring Boot 和 Kubernetes 如何极大地简化这项任务。 Spring Batch 是 JVM
大数据编排引擎历史回顾 - Ananth
我在 Hadoop/Bigdata 的早期阶段开始研究数据管道,当时大数据是一个流行词。Apache Oozie (有人还记得 Oozie 吗?)是一种用于编排数据管道的
Windmill:最快的自托管开源工作流引擎
我们对 Windmill 进行了基准测试,认为它是 Airflow、Prefect 甚至 Temporal 中最快的自托管通用工作流引擎。对于 Airflow,有速度快了 10 倍! 工作流引擎编排工作人员的有向无环图 (DAG) 中定义的作业,同
Jellysmack如何将数据科学作业编排推向生产就绪水平?
自从数据科学进入 IT 游戏并开始构建大量模型和项目以来,对工作编排的需求已经上升。由于 Jellysmack 的业务主要集中在帮助视频创作者在观众和质量方面增长,我们的许多团队都依赖从 YouTube(或其他社交平台,如 Facebook、Snapchat 等)提取的数据。这正是定义工作的
River:Go中快速可靠的事务性后台作业
使用像 PostgreSQL 这样的关系数据库作为作业队列是一种可以接受的方法,一些公司在生产中成功使用了这种方法。虽然 Redis 等更传统的队列可能更适合高吞吐量低延迟用例,但数据库可以为作业处理提供事务保证。不需要长时间超时的短作业可以很好地工作。前提是如果每秒处理 10K 事务并且作
运行部署时可拆分工作负载的单体架构
微服务会带来大量相关包袱问题(分布式系统问题、RPC 框架等)。如果我们想要在没有包袱的情况下享受微服务的好处,我们将需要一些替代解决方案。 规则 1:永远不要混合工作负载首先,我们应该应用运行单体的基本规
Solid Queue:Ruby中基于数据库的后端队列作业系统
Solid Queue 是一个基于数据库的Active Job队列后端,设计时考虑到了简单性和性能。
GoLang中后台作业终极指南
在这篇博文中,我们将探讨GoLang、Redis和 Gocraft的强大组合,以及它们如何将您的Web 开发项目提升到一个新的水平。 GoLang是一种流行的编程语言,以其速度、并发性和效率而闻名,通常需要后台进程在不阻塞主线程的情况下处理任务。 后台作业是在主程序继续运行时
构建微服务分布式作业调度器 - Mesut
本文将帮助您以您可以配置的标准方式自动化您的工作。它还可以通过各种方式触发您的作业并执行您的业务代码。调度作业的方法有很多,包括cron 作业和Windows 任务调度程序,但这些解决方案对用户不友好并且依赖于平台。如果你在云环境(AWS、GCP、Azure 等)上运行,那么你可以使
Kestra 简介:开源编排和调度平台
公司建立数据管道以准备数据成分、提取见解并在内部和外部各方之间分发调查结果。处理各种海量数据的能力已成为推动业务成功的关键因素。然而,构建和管理数据流并不简单。您必须考虑从不同来源提取数据的时间表和计划。当您最终将原始数据或转换后的数据保存到数据仓库中时,您必须考虑转换、建模和聚合。它很容易
Lyft 市场中流媒体管道的演变
Lyft 撰写了有关其基于 Apache Beam 的流式管道架构的演变。该博客讲述了初始版本是如何从 cron 作业开始的,以及为简化管道创建而进行的持续改进。 背景2017 年,我们 Marketpla
BinChengZhao/delicate :Rust编写一个轻量的分布式的任务调度平台
delicate 一个轻量的分布式的任务调度平台通过rust编写. :特性 友好的用户界面: [前端]方便地管理任务和执行器,监控其状态,支持手动维护运行中的任务等。 灵活的操作: 灵活的任务操作,支持限制单个节点的最大并行数,与cron表达式相对应的时区设置
Fang:实现Rust异步后台处理
尽管 Rust 的第一个稳定版本于 2015 年发布,但其生态系统中仍然存在一些用于解决常见任务的漏洞。其中之一是后台处理。在软件工程中,后台处理是解决几个问题的常用方法: 执行定期任务。例如,传递通知、更新缓存值。 推迟昂贵的工作,以便您的应用程序在后台执行
Apache Airflow的10条最佳实践
最初,Airflow 有点像“超级 cron”,因此运行作业的方式与框架本身高度耦合。今天,您必须克服的最大挑战是消除调度和作业之间的耦合。 1)Airflow是一个编排框架,而不是一个执行框架:对于您的工
上页
下页