首页 编程相关 正文
我要发布

titanoboa

编程相关
2025-12-11 0 361

概要

titanoboa使复杂的工作流程变得容易。

它是一个完全分布式的，高度可扩展的低代码工作流编排平台。
它在JVM上运行，并支持Java，Kotlin＆Clojure。 （Python也来了！）
您可以在任何地方运行它：本地或云中；在裸金属，VM，Docker或K8上。
titanoboa支持聚类，您可以轻松地扩展到数百个节点。

由于其通用，分布式且易于扩展的设计，您可以将titanoboa用于各种各样的目的。
您可以使用它：

  • 用于大数据处理和数据管道自动化
  • 用于编排核心微服务– 作为复合微服务的替代
  • 作为功能齐全的IPAA /集成平台
  • 用于数据转换 / ETL
  • 因为它自动化
  • 作为服务巴士（ESB）
  • 用于批处理处理

另请参见titanoboa .io和我们的Wiki。预定义的工作流程步骤在这里。

动机

titanoboa创建旨在创建一个工作流平台，该平台将支持复杂工作流引擎和大多数企业集成模式的所有常规功能，包括：

  • 顺序和/或并行步骤执行
  • 可配置的步骤在错误和高级可自定义错误处理时重试
  • 高级分支和条件流
  • 潜在的循环工作流程图
  • 分离器和聚合器（又名MAP/降低）模式，该模式允许处理较大的数据集
  • 完全交易的性质确保即使发生故障转移，所有步骤也是执行的
  • 在运行时迅速开发和部署新工作流程的完全可扩展性和能力

除了这项titanoboa之外，还努力尊重不可分割的性能和功能编程原则。这使得它可以完全分发并在没有中央主服务器或数据库的情况下高度使用。这也有助于提高性能限制，因此titanoboa不仅适合批处理处理，而且适用于绩效关键工作流程。

titanoboa的浏览器GUI不仅可用于监视工作流程作业和服务器配置，而且还可以提供具有工作流可视化，高级数据和属性编辑器，AutComplete功能和一个重置（即使是Java！）的内置构建IDE，以便用户可以快速直接在那里进行测试开发新的工作。

titanoboa是专为Java＆Clojure开发人员设计的，我们正在努力使其即使对于没有任何Clojure知识的Java开发人员也可以使用。

要了解titanoboa背后的一些概念及其如何使用，请随时观看此RE：Clojure Conference Talk：

预定义步骤

尽管很容易直接从GUI（如我们的演示中显示）快速开发新的工作流程步骤，但是此存储库中有许多现成的步骤和任务。包括的一些步骤是：

  • AWS（EC2，S3，SNS，SQS，SES）
  • JDBC客户端
  • HTTP客户端
  • SMTP客户端
  • sftp
  • PDF世代

还有更多。

如果您创建了自己的自定义步骤（以Java或Clojure为单位），并且希望在其他工作流程中重复使用它们，那么将自己的自定义现成步骤添加到GUI中非常容易 – 请参阅我们的Wiki。您甚至可以添加自定义图标！

先决条件

Java 8或更高。

Docker

Docker Image可以在titanoboa / titanoboa中获得，您可以按照以下方式运行它：

titanoboa / titanoboa :0.9.0\”>

 docker run -d -p 3000:3000 --name titanoboa titanoboa / titanoboa :0.9.0

安装

顺便说一句，您无需安装任何内容，因为您只需单击即可在浏览器中启动一个免费的托管实例！只需前往https://cloud.**tit*anoboa.io

但是，如果愿意，请安装！我们建议可以尝试titanoboa的GUI，因为这是最好的起点！从https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/ titanoboa -0.9.9.1_gui.zip下载titanoboa的发行版。 

 curl --remote-name https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/ titanoboa -0.9.1_gui.zip

注意： GUI现在也可以免费用于商业用途。耶！

注意：如果您打算在Java 8 JRE上运行titanoboa服务器，请下载JRE的发行版： 

 curl --remote-name https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/ titanoboa -0.9.1_jre_gui.zip

解压缩文件： 

 unzip titanoboa -0.9.1_gui.zip

然后执行开始脚本： 

 ./start

在您的控制台中，您应该看到一堆日志消息，最终您会看到

 INFO [main] - Started @2338ms

这意味着服务器成功启动。默认情况下，服务器和GUI都将在端口3000上启动，您可以在浏览器中打开http：// localhost：3000。

恭喜！您刚刚启动了titanoboa服务器！

您可以继续尝试创建示例工作流程或观看我们的演示。

没有GUI的服务器

从https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/titanoboa titanoboa下载最新版本。 

 curl --remote-name https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/ titanoboa -0.9.1.zip

注意：如果您打算在Java 8 JRE上运行titanoboa服务器，请下载JRE的发行版： 

 curl --remote-name https://g*i*thub.co*m/mikub/titanoboa/releases/download/0.9.1/ titanoboa -0.9.1_jre.zip

然后按照上述说明进行操作。默认情况下，服务器将在端口3000上启动。

从存储库建造

这些步骤在我们的Wiki上描述。

服务器配置

服务器配置和外部依赖项文件可以由System属性boa.server.config.path和boa.server.dependencies.path指定：

titanoboa .server\”>

 java -Dboa.server.config.path=boa_server_config_local.clj -Dboa.server.dependencies.path=ext-dependencies.clj -cp \"./build/ titanoboa .jar:./lib/*\" titanoboa .server

有关更多详细信息，请参见服务器配置Wiki。

入门

在开始之前，熟悉titanoboa的概念和工作流设计原理可能是一个好主意。

还可以随时观看Re：Clojure 2020 Conference的Miro的演讲，该会议很好地概述了titanoboa可以做什么。

使用titanoboa GUI开发和测试工作流程

titanoboa GUI是开始开发和测试工作流程的好地方：

在Wiki中查看如何创建示例工作流程的示例。

在Java中开发自定义工作流程步骤

titanoboa也应被Java开发人员使用（除了像EDN这样的概念之外）不需要熟悉Clojure。如果您不想使用Clojure Java Interop实例化对象和/或调用您的方法，那么您也有其他选择：

要创建自定义工作流程步骤，只需在项目中添加（Maven）依赖性即可。并创建一个将实现IO的类。 titanoboa .java.iworkloadfn接口： 

 public interface IWorkloadFn {
   public Object invoke ( Map properties );
}

如果然后将项目（或相应的Maven伪像）添加到titanoboa的外部依赖项中，则可以在Workflow-FN字段中使用类名。该类将自动实例化为单例bean（因此必须具有一个没有Argumet的构造函数），并且从任何Workflow-FN中对其进行所有后续引用都将调用其调用方法： 

:workload-fn io. titanoboa .java.SampleWorkloadImpl

或者

:workload-fn \'io. titanoboa .java.SampleWorkloadImpl

或在GUI中：

Java Lambda支持

为了快速开发和测试新步骤，您还可以在GUI中键入Lambda功能，并在运行时对titanoboa进行评估。在此处阅读有关它的更多信息，或者在我们的演示中查看它是如何完成的。

在您的clojure repl中本地开发和测试工作流程

如果您不能使用GUI并且不想使用REST API，则可以在本地启动并在那里使用titanoboa播放。要么是从仓库中构建titanoboa ，要么将其作为Leiningen或Maven依赖性构建：

titanoboa \”0.9.0\”]\”>

[io. titanoboa / titanoboa \" 0.9.0 \" ]

titanoboa</groupId>
<artifactId> titanoboa </artifactId>
<version>0.9.0</version>
</dependency>\”>

< dependency >
  < groupId >io. titanoboa </ groupId >
  < artifactId > titanoboa </ artifactId >
  < version >0.9.0</ version >
</ dependency >

然后启动一个替补开始：

定义样本“ Hello World！”工作流：

titanoboa.system]
[ titanoboa .repo]
[ titanoboa .system.local]
[ titanoboa .processor]))

(defn hello-fn [p]
{:message (str \”Hello \” (or (:name p) \”human\”) \”!\”)
:return-code (nil? (:name p))})

(defn greet-fn [p]
{:message (str (:message p) \” Nice to meet you!\”)})

(defn fill-in-blanks [p]
{:message (str (:message p) \” What is your name?\”)})

(def job-def {:first-step \”step1\”
:name \”test\”
:properties {:name nil}
:steps [{:id \”step1\”
:type :custom
:supertype :tasklet
:next [[false \”step2\”] [true \”step3\”]]
:workload-fn \’local-system-test/hello-fn
:properties {}}
{:id \”step2\” :type :custom :supertype :tasklet
:workload-fn \’local-system-test/greet-fn
:next []
:properties {}}
{:id \”step3\” :type :custom :supertype :tasklet
:workload-fn \’local-system-test/fill-in-blanks
:next []
:properties {}}]})\”>

( ns local-system-test
  ( :require [ titanoboa .system]
            [ titanoboa .repo]
            [ titanoboa .system.local]
            [ titanoboa .processor]))

( defn hello-fn [p]
  { :message ( str \" Hello \" ( or ( :name p) \" human \" ) \" ! \" )
   :return-code ( nil? ( :name p))})

( defn greet-fn [p]
  { :message ( str ( :message p) \" Nice to meet you! \" )})

( defn fill-in-blanks [p]
  { :message ( str ( :message p) \" What is your name? \" )})
  
( def job-def { :first-step \" step1 \"
              :name       \" test \"
              :properties { :name nil }
              :steps      [{ :id          \" step1 \"
                            :type :custom
                            :supertype :tasklet
                            :next [[ false \" step2 \" ] [ true \" step3 \" ]]
                            :workload-fn \'local-system-test/hello-fn
                            :properties  {}}
                           { :id          \" step2 \" :type :custom :supertype :tasklet
                            :workload-fn \'local-system-test/greet-fn
                            :next        []
                            :properties  {}}
                           { :id          \" step3 \" :type :custom :supertype :tasklet
                            :workload-fn \'local-system-test/fill-in-blanks
                            :next        []
                            :properties  {}}]})

从可以处理工作的工人开始简单的本地系统：

titanoboa.system/start-system! :core-local
{:core-local {:system-def #\’ titanoboa .system.local/local-core-system
:worker-def #\’ titanoboa .system.local/local-worker-system
:worker-count 2}}
{:new-jobs-chan new-jobs-chan
:jobs-chan jobs-chan
:finished-jobs-chan finished-jobs-chan
:node-id \”localhost\”
:eviction-interval (* 1000 60 5)
:eviction-age (* 1000 60 10)
:jobs-repo-path \”repo-test/\”
:job-folder-path \”job-folders/\”})

INFO [nREPL-worker-0] – Starting system :core-local …
INFO [nREPL-worker-0] – Starting CacheEvictionComponent…
INFO [CacheEvictionComponent thread 0] – Starting CacheEvictionComponent thread [ CacheEvictionComponent thread 0 ].
INFO [nREPL-worker-0] – Starting action processor pool…
INFO [nREPL-worker-0] – Starting to watch repo folder for changes: dev-resources/repo-test/
INFO [nREPL-worker-0] – System :core-local started
=> true

( titanoboa .system/start-workers! :core-local
{:core-local {:system-def #\’ titanoboa .system.local/local-core-system
:worker-def #\’ titanoboa .system.local/local-worker-system
:worker-count 2}})

INFO [nREPL-worker-1] – Starting 2 workers for system :core-local :
INFO [nREPL-worker-1] – Starting a worker for system :core-local …
INFO [nREPL-worker-1] – Starting job worker….
INFO [nREPL-worker-1] – Starting a worker for system :core-local …
INFO [nREPL-worker-1] – Starting job worker….
=> nil \”>

( def new-jobs-chan ( clojure.core.async/chan ( clojure.core.async/dropping-buffer 1024 )))
( def jobs-chan ( clojure.core.async/chan ( clojure.core.async/dropping-buffer 1024 )))
( def finished-jobs-chan ( clojure.core.async/chan ( clojure.core.async/dropping-buffer 1024 )))

( titanoboa .system/start-system! :core-local
                                  { :core-local { :system-def   #\' titanoboa .system.local/local-core-system
                                          :worker-def   #\' titanoboa .system.local/local-worker-system
                                          :worker-count 2 }}
                                  { :new-jobs-chan      new-jobs-chan
                                   :jobs-chan          jobs-chan
                                   :finished-jobs-chan finished-jobs-chan
                                   :node-id            \" localhost \"
                                   :eviction-interval  ( * 1000 60 5 )
                                   :eviction-age       ( * 1000 60 10 )
                                   :jobs-repo-path     \" repo-test/ \"
                                   :job-folder-path    \" job-folders/ \" })
                                   
 INFO [nREPL-worker-0] - Starting system :core-local ...
 INFO [nREPL-worker-0] - Starting CacheEvictionComponent...
 INFO [CacheEvictionComponent thread 0 ] - Starting CacheEvictionComponent thread [ CacheEvictionComponent thread 0 ].
 INFO [nREPL-worker-0] - Starting action processor pool...
 INFO [nREPL-worker-0] - Starting to watch repo folder for changes:  dev-resources/repo-test/
 INFO [nREPL-worker-0] - System :core-local started
=> true
 
( titanoboa .system/start-workers! :core-local
                                   { :core-local { :system-def   #\' titanoboa .system.local/local-core-system
                                           :worker-def   #\' titanoboa .system.local/local-worker-system
                                           :worker-count 2 }})
                                           
 INFO [nREPL-worker-1] - Starting 2 workers for system :core-local :
 INFO [nREPL-worker-1] - Starting a worker for system :core-local ...
 INFO [nREPL-worker-1] - Starting job worker....
 INFO [nREPL-worker-1] - Starting a worker for system :core-local ...
 INFO [nREPL-worker-1] - Starting job worker....
=> nil

开始工作：

titanoboa.processor/run-job! :core-local
{:jobdef job-def
:properties {:name \”World\”}}
true)

INFO [nREPL-worker-2] – Submitting new job [] into new jobs channel…
INFO [async-thread-macro-2] – Initializing a new job; First step will be: [ step1 ]
INFO [async-thread-macro-2] – Retrieved job [ d673c759-4fc6-4af1-bdad-d1dfd0f50f22 ] from jobs channel; Starting step [ step1 ]
INFO [async-thread-macro-2] – Next step is step2 ; Submitting into jobs channel for next step\’s processing…
INFO [async-thread-macro-1] – Initializing a next step; next step [ step2 ] was found among steps as step [ step2 ]
INFO [async-thread-macro-2] – Acking main message for step step1 with thread stack nil
INFO [async-thread-macro-1] – Retrieved job [ d673c759-4fc6-4af1-bdad-d1dfd0f50f22 ] from jobs channel; Starting step [ step2 ]
INFO [async-thread-macro-1] – Looping through finalize-job! fn with thread-stack: []
INFO [async-thread-macro-1] – Acking main message for step step2 with thread stack nil
INFO [async-thread-macro-1] – Job d673c759-4fc6-4af1-bdad-d1dfd0f50f22 has finshed.
=>
{:properties {:name \”World\”, :message \”Hello World! Nice to meet you!\”},
:step-start #inst\”2018-11-23T07:35:34.218-00:00\”,
:step-retries {},
:tracking-id nil,
:step-state :completed,
:start #inst\”2018-11-23T07:35:34.203-00:00\”,
:history [{:step-state :completed,
:start #inst\”2018-11-23T07:35:34.210-00:00\”,
:duration 6,
:result false,
:node-id \”localhost\”,
:id \”step1\”,
:next-step \”step2\”,
:exception nil,
:end #inst\”2018-11-23T07:35:34.216-00:00\”,
:retry-count nil,
:thread-stack nil,
:message \”Step [step1] finshed with result [false]\\n\”}
{:id \”step2\”,
:step-state :running,
:start #inst\”2018-11-23T07:35:34.218-00:00\”,
:node-id \”localhost\”,
:retry-count 0}
{:step-state :completed,
:start #inst\”2018-11-23T07:35:34.218-00:00\”,
:duration 1,
:result nil,
:node-id \”localhost\”,
:id \”step2\”,
:next-step nil,
:exception nil,
:end #inst\”2018-11-23T07:35:34.219-00:00\”,
:retry-count nil,
:thread-stack nil,
:message \”Step [step2] finshed with result []\\n\”}],
:duration 16,
:state :finished,
:jobid \”d673c759-4fc6-4af1-bdad-d1dfd0f50f22\”,
:create-folder? true,
:node-id \”localhost\”,
:next-step nil,
:end #inst\”2018-11-23T07:35:34.219-00:00\”}\”>

( titanoboa .processor/run-job! :core-local
                              { :jobdef job-def
                               :properties { :name \" World \" }}
                              true )

 INFO [nREPL-worker-2] - Submitting new job [] into new jobs channel...
 INFO [async-thread-macro-2] - Initializing a new job ; First step will be: [ step1 ]
 INFO [async-thread-macro-2] - Retrieved job [ d673c759-4fc6-4af1-bdad-d1dfd0f50f22 ] from jobs channel ; Starting step [ step1 ]
 INFO [async-thread-macro-2] - Next step is  step2 ; Submitting into jobs channel for next step\'s processing...
 INFO [async-thread-macro-1] - Initializing a next step ; next step [ step2 ] was found among steps as step [ step2 ]
 INFO [async-thread-macro-2] - Acking main message for step  step1  with thread stack  nil
 INFO [async-thread-macro-1] - Retrieved job [ d673c759-4fc6-4af1-bdad-d1dfd0f50f22 ] from jobs channel ; Starting step [ step2 ]
 INFO [async-thread-macro-1] - Looping through finalize-job! fn with thread-stack:  []
 INFO [async-thread-macro-1] - Acking main message for step  step2  with thread stack  nil
 INFO [async-thread-macro-1] - Job  d673c759-4fc6-4af1-bdad-d1dfd0f50f22  has finshed.
=>
{ :properties { :name \" World \" , :message \" Hello World! Nice to meet you! \" },
 :step-start #inst \" 2018-11-23T07:35:34.218-00:00 \" ,
 :step-retries {},
 :tracking-id nil,
  :step-state :completed ,
 :start #inst \" 2018-11-23T07:35:34.203-00:00 \" ,
 :history [{ :step-state :completed ,
            :start #inst \" 2018-11-23T07:35:34.210-00:00 \" ,
            :duration 6 ,
            :result false ,
            :node-id \" localhost \" ,
            :id \" step1 \" ,
            :next-step \" step2 \" ,
            :exception nil,
            :end #inst \" 2018-11-23T07:35:34.216-00:00 \" ,
            :retry-count nil,
            :thread-stack nil,
            :message \" Step [step1] finshed with result [false] \\n \" }
           { :id \" step2 \" ,
            :step-state :running ,
            :start #inst \" 2018-11-23T07:35:34.218-00:00 \" ,
            :node-id \" localhost \" ,
            :retry-count 0 }
           { :step-state :completed ,
            :start #inst \" 2018-11-23T07:35:34.218-00:00 \" ,
            :duration 1 ,
            :result nil,
            :node-id \" localhost \" ,
            :id \" step2 \" ,
            :next-step nil,
            :exception nil,
            :end #inst \" 2018-11-23T07:35:34.219-00:00 \" ,
            :retry-count nil,
            :thread-stack nil,
            :message \" Step [step2] finshed with result [] \\n \" }],
 :duration 16 ,
 :state :finished ,
 :jobid \" d673c759-4fc6-4af1-bdad-d1dfd0f50f22 \" ,
 :create-folder? true ,
 :node-id \" localhost \" ,
 :next-step nil,
 :end #inst \" 2018-11-23T07:35:34.219-00:00 \" }

完成测试后，您可能需要停止系统：

titanoboa.system/stop-all-systems!)

INFO [nREPL-worker-3] – Stopping all workers for system :core-local
INFO [nREPL-worker-3] – Stopping job worker gracefully; sending a stop signal to the worker via service bus….
INFO [nREPL-worker-3] – Stopping job worker gracefully; sending a stop signal to the worker via service bus….
INFO [nREPL-worker-3] – Stopping system :core-local …
INFO [nREPL-worker-3] – Stopping action processor pool…
INFO [nREPL-worker-3] – Stopping CacheEvictionComponent thread [ CacheEvictionComponent thread 0 ]…\”>

( titanoboa .system/stop-all-systems! )

 INFO [nREPL-worker-3] - Stopping all workers for system :core-local
 INFO [nREPL-worker-3] - Stopping job worker gracefully ; sending a stop signal to the worker via service bus....
 INFO [nREPL-worker-3] - Stopping job worker gracefully ; sending a stop signal to the worker via service bus....
 INFO [nREPL-worker-3] - Stopping system :core-local ...
 INFO [nREPL-worker-3] - Stopping action processor pool...
 INFO [nREPL-worker-3] - Stopping CacheEvictionComponent thread [ CacheEvictionComponent thread 0 ]...

执照

版权所有©Commsor Inc.

titanoboa已获得AGPL许可证的许可。

下载源码

通过命令行克隆项目:

git clone https://github.com/commsor/titanoboa.git

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在
点赞 (0)

申明：本文由第三方发布，内容仅代表作者观点，与本网站无关。对本文以及其中全部或者部分内容的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。本网发布或转载文章出于传递更多信息之目的，并不意味着赞同其观点或证实其描述，也不代表本网对其真实性负责。

左子网 编程相关 titanoboa https://www.zuozi.net/34335.html

openrndr
上一篇： openrndr
scala logging
下一篇： scala logging
常见问题

发货方式是什么？

  • 1、自动：拍下后，点击（下载）链接即可下载；2、手动：拍下后，联系卖家发放即可或者联系官方找开发者发货。
查看详情

交易周期是多久呢？

  • 1、源码默认交易周期：手动发货商品为1-3天，并且用户付款金额将会进入平台担保直到交易完成或者3-7天即可发放，如遇纠纷无限期延长收款金额直至纠纷解决或者退款！；
查看详情

能退款么？

  • 1、描述：源码描述(含标题)与实际源码不一致的（例：货不对板）； 2、演示：有演示站时，与实际源码小于95%一致的（但描述中有”不保证完全一样、有变化的可能性”类似显著声明的除外）； 3、发货：不发货可无理由退款； 4、安装：免费提供安装服务的源码但卖家不履行的； 5、收费：价格虚标，额外收取其他费用的（但描述中有显著声明或双方交易前有商定的除外）； 6、其他：如质量方面的硬性常规问题BUG等。 注：经核实符合上述任一，均支持退款，但卖家予以积极解决问题则除外。
查看详情

注意事项

  • 1、左子会对双方交易的过程及交易商品的快照进行永久存档，以确保交易的真实、有效、安全！ 2、左子无法对如“永久包更新”、“永久技术支持”等类似交易之后的商家承诺做担保，请买家自行鉴别； 3、在源码同时有网站演示与图片演示，且站演与图演不一致时，默认按图演作为纠纷评判依据（特别声明或有商定除外）； 4、在没有”无任何正当退款依据”的前提下，商品写有”一旦售出，概不支持退款”等类似的声明，视为无效声明； 5、在未拍下前，双方在QQ上所商定的交易内容，亦可成为纠纷评判依据（商定与描述冲突时，商定为准）； 6、因聊天记录可作为纠纷评判依据，故双方联系时，只与对方在左子上所留的QQ、手机号沟通，以防对方不承认自我承诺。 7、虽然交易产生纠纷的几率很小，但一定要保留如聊天记录、手机短信等这样的重要信息，以防产生纠纷时便于左子介入快速处理。
查看详情

相关文章

猜你喜欢
发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务

联系官方团队 在线提交工单
TA的动态
左子网

分享最新WordPress教程共同学习，共同进步，共同成长！

QQ交流群
左子网

QQ交流群

您的支持，是我们最大的动力！ https://qm.qq.com/q/iR7Nj0TrOg
热门文章
热门标签
随机推荐
热门评论
终身VIP会员限时钜惠
首页 源码 菜单 案例 我的