是否有可能創建一個我可以手動運行的AWS數據管道,當我觸發它時,我希望傳遞參數來執行。是否可以創建一個可以手動觸發參數的aws數據管道?
回答
當你說「手動運行管道」時,你的意思是什麼?
通過調用activate-pipeline命令可以從命令行激活(「觸發」)管道。該命令需要管道標識並可選擇接受參數值bag作爲管道配置。爲了獲得更多的細節有關此命令,運行
AWS datapipeline激活流水線幫助
例如
AWS datapipeline激活流水線--pipeline-ID DF-ABCDEF1234 --parameter值myStringValue = 「Hello World」 的myArrayValue =值myArrayValue =數值
或
AWS datapipeline activate-pipeline --pipeline-id df-ABCDEF1234 --parameter-values-uri s3://myBucket/withParameters/forPipeline.json
不,數據管道中目前不支持。我相信你正在尋找的是事件驅動調度有可能爲特定運行實例提供參數。
我建議你去探索以下選項:
使用- 拉姆達 - 支持的基礎上,從S3觸發器執行任意代碼。然後使用S3爲運行實例提供無或輸入(充當參數)。
- 使用AWS SWF和SQS
構建自己有黑客,使其與數據管道的工作,但我會建議採取沒有這些,等待數據管道,以支持此功能。
哈克#1:
你可以讓一個時間表您的管道運行。你的管道將有三個組成部分:
- ShellCommandActivity(與來自S3臨時文件運行shell腳本數據管道不從S3文件緩存到你的資源。)
- S3前提
- (可選)資源來運行你的ShellCommandActivity
現在在你的shell腳本中檢查S3文件。你可以有邏輯來讓這個執行成爲一個無操作,如果沒有/空文件在S3中或讀取S3文件並將它們作爲參數傳遞給你的程序。
哈克#2:
您可以添加S3先決條件(指向的位置說:S3://我的桶/標記文件 - #{} scheduledStartTime)向您的管道活動中,充當您的觸發機制。無論何時您想要進行特定的時間間隔運行,您都可以在S3中放入相應的文件(比如s3:// my-bucket/marker-file-2015-10-01:00:00:00)。
這個破解非常糟糕,我對解釋更多不滿意。
是的,這是可能的。由於您發佈了您的問題,AWS已創建新的「scheduleType
」,ondemand
,它允許您在調用「激活管道」時運行管道。這裏是一個例子invoking a pipeline via AWS Lambda。
- 1. 是否可以手動觸發引導下拉創建? (VueJS)
- 2. 是否可以創建管道模板,以便Jenkins自動生成管道?
- 3. 是否可以在scrapy中動態創建管道?
- 4. 在TransactSQL中,是否可以創建一個接受可變數量參數(可選參數)的函數?
- 5. 是否可以一次創建多個數據框?
- 6. 是否可以給管道char'|'作爲命令行參數?
- 7. 您是否可以在動態計時器上觸發AWS Lambda?
- 8. 是否可以使用MSpec創建數據驅動的測試?
- 9. 是否可以創建一個僅限CSS的手風琴?
- 10. hibernate是否可以創建數據庫和數據庫用戶?
- 11. 是否可以創建一個計算指令數量的Monad?
- 12. 是否可以在數組中創建動態數量的列?
- 13. 是否可以開發pass創建者?
- 14. 是否可以通過Linux bash管道以某種方式傳遞參數?
- 15. 是否有可能在數據庫中創建一個非手動的MySQL表?
- 16. 是否可以創建可以自動調整大小的點?
- 17. 是否可以在C#中的參數名稱中創建一個對象?
- 18. 是否可以在Java中創建一個BufferedWriters數組?
- 19. 是否可以在Swift中創建一個數組擴展?
- 20. 是否可以創建一個變量名稱數組?
- 21. 是否可以通過WebSocket握手發送自定義數據?
- 22. 是否可以編寫一個函數模板來返回參數個數是否可以被N整除?
- 23. 是否可以動態創建htmlhelpers?
- 24. 是否可以使用FluentMigrator創建觸發器?
- 25. 與創建一個管道,以及如何隔離數據
- 26. 函數是否可以繼承參數?
- 27. 是否可以創建一個自定義的動畫MKAnnotationView?
- 28. 是否可以創建一個動態的JPQL查詢?
- 29. 是否可以手動確認TCP數據包?
- 30. 解構函數參數時可以創建一個對象嗎?