關於使用彈簧雲流作爲源執行的任務的說明

Question

當閱讀this documentation時，似乎我們可以編寫一個帶有@EnableTask的微服務，該服務具有一個源，其發送的消息作爲spring-cloud-task的執行步驟被記錄。

我想對此聲明有幾點澄清，以實現這一點沒有spring-cloud-dataflow：

• 這是否意味着，如果我們有一個Source豆與InboundChannelAdapter，我們並不需要聲明CommandLineRunner？
• 通過定義一個任務應該發出的數據的一個時間，如何再現與調查定期間隔Source這種行爲？
• ，我打算給spring-boot應用程序中混合使用@EnableTask和AggregateApplicationBuilder一些配置直接連接我的Source到Sink，而不需要利用Kafka或RabbitMQ，但似乎spring-cloud-task需要的粘合劑。有沒有辦法跳過它？

感謝

Answer 1

什麼是可利用的今天是聽任務的生命週期事件，並將它們發佈到一個名爲（重寫）信道用於下游分析/處理目標的能力。這隻需通過在類路徑中實現特定的Spring Cloud Stream的綁定器即可實現自動化。

這是否意味着如果我們有一個帶有InboundChannelAdapter的Source bean，我們不需要聲明一個CommandLineRunner？

好像你想在你的引導應用混合雲春流（SCST）和Spring雲任務（SCT）的註釋。這不是它打算如何使用。如果你還沒有準備好，請參閱this sample進行了解。

根據定義，任務預計會發出一次數據，如何重現這種行爲與定期間隔輪詢源？

任務運行時間爲「有限的時間段」，這是由嵌入應用程序的業務邏輯的運行時間來描述的。任務還需要某種形式的觸發器才能啓動。您可以使用調度程序進行重複定時啓動或通過流啓動它。這裏是你如何會在春季雲數據流（SCDF）流啓動它write-up。

如果你做到這一點民防部隊之外，你還上自己運行triggertask並設置正確的env-VAR的，所以流+任務應用程序通過公共信道目的地有關連。

...但它似乎彈簧雲的任務需要的粘合劑。有沒有辦法跳過它？

SCST與SCT之間的連接是通過spring-cloud-task-stream和spring-cloud-stream-binder-<type-of-binder>依賴性做，有沒有其他的方法了。