首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏Devops专栏

    8--Gradle进阶 - Gradle任务的入门、任务行为

    8--Gradle进阶 - Gradle任务的入门、任务行为 Gradle Task Gradle 项目工程的管理 实质上是 Task 对象的集合。 下面我们来看看如何编写 Gradle Task 任务。 task 任务,如下: 1685894623286 // 自定义的任务1 task("task1") { println "hello task1...." } // 自定义的任务2 task **提示 3:**区分任务的配置段和任务的行为,任务的配置段在配置阶段执行,任务的行为在执行阶段执行 任务的行为 doFirst、doLast 两个方法可以在任务内部定义,也可以在任务外部定义: // 自定义的任务3 task task3 { // 任务的配置阶段执行 println "hello task3...." // 任务的行为:在执行阶段执行,doFirst会在doLast

    94640编辑于 2023-09-01
  • 来自专栏数据科学(冷冻工厂)

    Python 异步: 使用和查询任务8

    任务是异步程序的货币。在本节中,我们将仔细研究如何在我们的程序中与它们交互。1. 任务生命周期异步任务具有生命周期。首先,任务是从协程创建的。然后安排在事件循环中独立执行。在某个时候,它会运行。 图片现在我们已经从高层次上熟悉了任务的生命周期,让我们仔细看看每个阶段。2. 如何检查任务状态创建任务后,我们可以检查任务的状态。 我们可能要检查两种状态,它们是:任务是否完成任务是否取消让我们依次仔细看看每一个。2.1. 检查任务是否完成我们可以通过 done() 方法检查任务是否完成。 已安排的任务未完成。同样,正在运行的任务未完成。如果出现以下情况,则完成任务:协程正常结束。协程显式返回。协程中出现意外错误或异常任务被取消。2.2. 如何获取任务异常任务包装的协程可能会引发未处理的异常。这实际上会取消任务。我们可以通过 exception() 方法在任务包装的协程中检索未处理的异常。...

    1.8K01编辑于 2023-02-09
  • 来自专栏数据科学(冷冻工厂)

    Python 异步: 使用和查询任务8

    任务是异步程序的货币。在本节中,我们将仔细研究如何在我们的程序中与它们交互。 1. 任务生命周期 异步任务具有生命周期。首先,任务是从协程创建的。然后安排在事件循环中独立执行。 现在我们已经从高层次上熟悉了任务的生命周期,让我们仔细看看每个阶段。 2. 如何检查任务状态 创建任务后,我们可以检查任务的状态。 我们可能要检查两种状态,它们是: 任务是否完成 任务是否取消 让我们依次仔细看看每一个。 2.1. 检查任务是否完成 我们可以通过 done() 方法检查任务是否完成。 如果任务有机会运行但现在不再运行,则该任务已完成。已安排的任务未完成。同样,正在运行的任务未完成。 如果出现以下情况,则完成任务: 协程正常结束。 协程显式返回。 如何获取任务异常 任务包装的协程可能会引发未处理的异常。这实际上会取消任务。 我们可以通过 exception() 方法在任务包装的协程中检索未处理的异常。

    1.6K50编辑于 2023-02-27
  • 来自专栏开源技术小栈

    ThinkPHP8.X〡Queue 异步任务队列应用

    任务发布 消息的消费与删除 创建RestyJob消费者类 <? 当前任务将由哪个类来负责处理。 --queue dismiss_job_queue 要处理的队列的名称 --delay 0 如果本次任务执行抛出异常且任务未被删除时,设置其下次执行前延迟多少秒,默认为0。 --sleep 3 如果队列中无任务则sleep多少秒后重新检查(work+daemon模式)或退出(listen或非daemon模式) --tries 2 如果任务已经超过尝试次数上限,则触发“任务尝试数超限 --sleep 3 如果队列中无任务,则多长时间后重新检查。 --tries 0 如果任务已经超过重发次数上限,则进入失败处理逻辑,默认为0。

    1.9K10编辑于 2025-07-24
  • kanass通关指南(8) - 如何进行任务管理

    点击添加事项->任务,填写任务标题与描述,选择任务类型等信息​添加任务属性说明属性是否必填描述标题必填任务标题,用来描述任务,支持修改描述非必填用来详细描述任务内容,支持上传图片,支持修改任务类型非必填用来标明任务类型 ,支持修改优先级非必填用来表示任务的优先级别,支持修改负责人必填当前任务的负责人,支持修改计划日期非必填用来表示当前任务需要完成的时间所属模块非必填用来表示当前任务属于哪个模块所属迭代非必填用来表示当前任务属于哪次迭代所属版本非必填用来表示当前任务属于哪个版本 2、查看与编辑任务任务创建成功后,点击任务名称,页面以开启右抽屉的形式打开任务详情页面。 用户可以在详情页面对任务进行查看与修改​查看与编辑任务编辑标题直接在详情页面点击标题,即可修改编辑描述点击描述上的编辑按钮,编辑后点击确认,编辑保存成功编辑其他字段其他字段直接点击下拉框,即可编辑3、删除任务任务列表中点击更多 删除任务4、任务关联4.1事项关联子事项点击任务并进入任务详情页面,点击子事项,此页面提供添加子任务和关联子任务功能。添加子任务:可以在当前页面通过填写任务名称,快速创建子任务。创建成功后自动关联。

    27244编辑于 2025-11-20
  • 来自专栏IT架构圈

    「走进k8s」Kubernetes1.15.1的定时任务任务管理(24)

    ③ 区别 Job负责处理任务,即仅执行一次的任务,它保证批处理任务的一个或多个Pod成功结束。而CronJob则就是在Job上加上了时间调度。 counter image: busybox command: - "bin/sh" - "-c" - "for i in 9 8 ,不符合任务的特性。 kubectl get podskubectl logs demo-job-xs8z4 job任务的pod,运行完毕后只有completed这种状态。打印了之前执行的脚本从9到1 ? image: busybox args: - "bin/sh" - "-c" - "for i in 9 8

    5K21发布于 2019-08-23
  • 来自专栏VTeam技术团队

    探索v8源码:事件循环 Microtasks (微任务)

    点击上方蓝字,发现更多精彩 导语 Microtasks(微任务)是事件循环中一类优先级比较高的任务,本文通过一个有趣的例子探索其运行时机。 而 Microtasks 是一类优先级比较高的任务,我们不能像 Macrotasks(宏任务) 一样插入 Macrotasks 队列末端,等待多个事件循环后才执行,而需要插入到 Microtasks 的队列里面 注意,chrome://tracing 中的 v8.xxx小写v开头的为 Blink 的调用, V8.xxx大写的V才是真正的V8引擎。 thirdparty/blink/renderer/bindings/core/v8/v8script_runner.cc v8::MaybeLocal<v8::Value> V8ScriptRunner 观察到的现象即是 "当浏览器 JS 引擎调用栈弹空的时候,才会执行 Microtasks 队列" 所以现在我如果问你,是不是 Macrotasks(宏任务)执行完才会执行 Microtasks 呢?

    2.1K81发布于 2021-04-19
  • 来自专栏大数据与云原生

    Spark源码分析-Spark-on-K8S任务调度

    spark的k8s模块的主要工作就是管理executor pod的数量和生命周期,并在活跃的pod上发起任务调度。 这里说的"发起",是因为所有的任务调度都由TaskSchedulerImpl来确定,spark-k8s调度模块(yarn同理)只是在适当的时机去发起调用,Taskscheduler最终决定将具体的任务调度到具体的 总结下,spark k8s调度模块要做的事情: 根据作业配置维护一定数量的Executor(Pod) 在Executor资源足够的情况下,发起Task调度 任务调度模块设计 整个调度系统采用"发布-订阅 任务调度代码实现 按照模块顺序,说明每个模块的类及作用。 生产者 生产者就是从k8s中不断获取ExecutorPod状态,并上报给存储模块。 ,就知道哪些任务该发往哪个executor了,通过调用rpc接口将任务通过网络发送即可。

    1.2K40编辑于 2022-03-30
  • 来自专栏Cell的前端专栏

    python 设置程序每天 8 点定时执行任务

    第二次运行后直接休眠一天,到每天早上 8 点执行任务。 (该程序需要一直挂着,保持网络不断) 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 import time while True: rest-1)*3600)/60),"分钟后发送数据") time.sleep(sleeptime) elif now_hour > "08": rest = 8 now_hour == "08": print("启动时北京时间为:" + time.strftime("%H:%M", time.localtime()), "\t 软件将在每天 8 # 以下为定时任务 print("数据") time.sleep(86400-int(now_min)*60)

    2.7K20编辑于 2022-02-25
  • 来自专栏田飞雨的专栏

    k8s 中定时任务的实现

    k8s 中有许多优秀的包都可以在平时的开发中借鉴与使用,比如,任务的定时轮询、高可用的实现、日志处理、缓存使用等都是独立的包,可以直接引用。 本篇文章会介绍 k8s 中定时任务的实现,k8s 中定时任务都是通过 wait 包实现的,wait 包在 k8s 的多个组件中都有用到,以下是 wait 包在 kubelet 中的几处使用: func ,但在 k8s 中用了更原生的方式,使用 time.Timer 实现的。 三、总结 本篇文章主要讲了 k8s 中定时任务的实现与对应包(wait)中方法的使用。 通过阅读 k8s 的源代码,可以发现 k8s 中许多功能的实现也都是我们需要在平时工作中用的,其大部分包的性能都是经过大规模考验的,通过使用其相关的工具包不仅能学到大量的编程技巧也能避免自己造轮子。

    1.8K10发布于 2019-12-19
  • 来自专栏雷子说测试开发

    解密python实现定时任务8种方式

    定时任务是编程中常见的需求,它可以按照预定的时间表执行特定的任务或操作。在Python中,有多种方法可以实现定时任务。 while True: task() time.sleep(60) # 休眠1min 结果: 定时任务执行中... 定时任务执行中... 定时任务执行中... 这是一个更灵活的解决方案,可以安排多个任务。 ,可以用于管理和调度定时任务。 它支持任务的异步执行和分布式部署。

    2K11编辑于 2023-12-20
  • 来自专栏AIoT技术交流、分享

    详解FreeRTOS:嵌入式多任务系统的任务等待和唤醒机制(理论篇—8

    用于任务访问IPC对象的等待机制主要有3种: 直接返回结果:任务直接返回访问结果,成功或者失败,注意因为中断不像任务那样能够被阻塞,所以中断必须采用本模式; 阻塞等待模式:任务如果访问IPC对象失败,则进入该 操作系统唤醒机制主要有以下3种模式: 当资源可使用时,唤醒该资源的全部等待任务。让这些任务与系统中的其他任务平等竞争资源。 这种策略会使系统瞬间繁忙,在参与竞争资源的所有任务中,最终只有一个任务获取到资源,没有得到资源的任务将再次进入资源的等待队列; 将该资源等待队列中的一个合适的任务唤醒。 这个任务将和系统中可能访问该资源的其他任务一起竞争这个资源。 如果这个任务最终没有竞争到资源,它会再次进入该资源的等待队列; 操作系统从等待队列中找到一个最佳的任务并立刻把资源交给它,这样该任务直接从释放资源的那个任务那里获得资源。

    1K30编辑于 2023-05-26
  • 来自专栏Devops专栏

    8. Celery 4.3.0 Periodic Tasks 周期性任务调度

    任务调度器 beat celery beat是一个调度器,它可以周期内指定某个worker来执行某个任务。如果我们想周期执行某个任务需要增加beat_schedule配置信息. CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/9' # 设置代理人broker BROKER_URL = 'redis://127.0.0.1:6379/8' 启动woker处理周期性任务: 启动周期性任务是无法在windows上运行的,我在Centos7上启动,只要能够访问作为broker的redis,那么就可以执行任务。 celery -A celery_tasks worker -l info --beat 启动日志如下: 当启动了之后,每隔5秒就执行一次my_task1,如下: 配置cron任务 如果我们想指定在某天某时某分某秒执行某个任务 ,可以执行cron任务, 增加配置信息如下: from celery.schedules import crontab # 配置周期性任务, 或者定时任务 CELERYBEAT_SCHEDULE =

    71820编辑于 2022-01-17
  • 来自专栏YP小站

    K8S部署分布式调度任务Airflow

    Kubernetes 1.20, 1.19, 1.18 1.20, 1.19, 1.18 PostgreSQL 9.6, 10, 11, 12, 13 9.6, 10, 11, 12, 13 MySQL 5.7, 8 5.7, 8 SQLite 3.15.0+ 3.15.0+ MSSQL(Experimental) 2017,2019 注意: MySQL 5.x 版本不能或有运行多个调度程序的限制——请参阅调度程序文档 StorageClass PS: 使用NAS极速存储 # 编辑 StorageClass 文件 $ vim alicloud-nas-airflow-test.yaml apiVersion: storage.k8s.io Airflow Ingress Nginx 访问入口 # 生成 ingress nginx 配置文件 $ vim airflow-ingress.yaml apiVersion: networking.k8s.io service: name: airflow-webserver port: number: 8080 # 应用到K8S

    3.9K30编辑于 2021-12-06
  • 来自专栏Owen's World

    centos 8利用crontab设置定时任务,crontab每秒运行

    centos 8利用crontab设置定时任务 一、安装   1、查看是否安装 crontab:rpm -qa | grep crontab 2、如果未安装,分别执行: yum -y install 四、查看crontab文件 crontab -l 四、创建一个crontab文件 1crontab -e 注意/var/spool/cron是用户任务,/etc/crontab是系统任务 think 定时任务 每分钟跑一次 */1 * * * * php /home/www/tp6/think zhang hink 定时任务 每秒跑一次 * * * * * /usr/wwwshell/ygkj/zhang.sh 可能有一个坑shell脚本 解决“/bin/bash^M: bad interpreter: No such file or directory” my.oschina.net/owenzhang24… 定时任务添加完后   //1小时中的第3分钟和第5分钟执行 0 17 * * * command  //每天中的17:00执行一次 3 2-12/2 * * * command  //每天的2:03,4:03,6:03,8:

    2.8K20编辑于 2021-12-08
  • 来自专栏大数据-BigData

    Flink SQL Gateway提交任务到flink on k8s集群

    本为以Flink 1.17版本为例,介绍一种在K8s中启动Flink SQL Gateway,并连接到通过Flink kubernetes operator启动的Flink Session集群上。 当然,在开始一切之前,你需要一些必要的环境: 一个K8s集群 K8s集群安装有kubectl、helm3工具 k8s集群可以访问docker hub/有一个自建docker仓库,可以将必要的镜像推送到此仓库

    1.9K30编辑于 2023-10-18
  • 来自专栏大数据-BigData

    Flink SQL Gateway提交任务到flink on k8s集群

    本为以Flink 1.17版本为例,介绍一种在K8s中启动Flink SQL Gateway,并连接到通过Flink kubernetes operator启动的Flink Session集群上。 当然,在开始一切之前,你需要一些必要的环境: 一个K8s集群 K8s集群安装有kubectl、helm3工具 k8s集群可以访问docker hub/有一个自建docker仓库,可以将必要的镜像推送到此仓库

    2.1K40编辑于 2023-10-18
  • 来自专栏golang与云原生

    【k8s】利用crobjob实现定时宿主机集群任务

    可以考虑这么个场景,服务商的服务集群以K8S部署在云端,并以一条防火墙策略放通某专线ip或端口,以供外部用户访问。 整体思路我们可以利用原生对象crobjob对宿主机进行防火墙策略起禁用,这样只需要在一个master节点执行k8s的api请求即可。

    47910编辑于 2024-03-20
  • 来自专栏腿子代码了专栏

    JS同步任务任务任务

    只有执行完前一个任务,才能执行后一个任务。 待执行任务种类 在JavaScript待执行任务中,主要分为两类 同步任务 异步任务 同步任务 所谓同步任务,就是非耗时任务,在主线程当中直接执行的任务 例如 console.log('同步任务'); 等等都属于同步任务,同步任务,直接在JS单线程当中执行 异步任务 异步任务,又称耗时任务,异步任务的执行浪费时间,容易造成线程的堵塞。 异步任务又分为微任务与宏任务。 //异步任务 }) 宏任务任务主要包括定时器、I/O等等 /* setTimeout setInterval I/O */ 执行优先级 在JS当中,其待执行任务的优先级为同步任务>微任务>宏任务 然后在次将微任务、宏任务依次拿出来执行,若是没有,则持续监听,直到有任务

    91640编辑于 2023-10-08
  • 来自专栏我的小碗汤

    k8s使用Job执行任务失败怎么办

    kubernetes 中使用 Job 和 CronJob 两个资源分别提供了一次性任务和定时任务的特性,这两种对象也使用控制器模型来实现资源的管理。 这篇文章来介绍Job执行如果失败了会怎么样呢?

    4.4K20发布于 2019-07-30
领券