第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

在 Flyte 中的任務(wù)之間傳遞 blob

在 Flyte 中的任務(wù)之間傳遞 blob

慕婉清6462132 2023-12-20 16:16:43
我正在嘗試創(chuàng)建一個(gè)需要在多個(gè)任務(wù)之間傳遞數(shù)據(jù)的Flyte工作流程。我查看了文檔中的示例之一,但嘗試盡可能少地重新創(chuàng)建 blob 傳遞,但我仍然無(wú)法讓它工作。這是我的完整工作流程定義(當(dāng)然,我的實(shí)際用例會(huì)產(chǎn)生更多數(shù)據(jù)):from flytekit.sdk.tasks import python_task, outputs, inputsfrom flytekit.sdk.types import Typesfrom flytekit.sdk.workflow import workflow_class, Output, Input@inputs(the_text=Types.String)@outputs(the_blob=Types.Blob)@python_taskdef create_blob(wf_params, the_text, the_blob):    fname = "a-file.txt"    with open(fname, "w") as f:        f.write(the_text)    the_blob.set(fname)@inputs(the_blob=Types.Blob)@outputs(the_text=Types.String)@python_taskdef read_blob(wf_params, the_blob, the_text):    the_blob.download()    with open(the_blob.local_path) as f:        the_text.set(f.read())@workflow_classclass PassBlob:    input_text = Input(Types.String, required=True, help="The text to write to the file")    create = create_blob(the_text=input_text)    read = read_blob(the_blob=create.outputs.the_blob)    output_text = Output(read.outputs.the_text, sdk_type=Types.String, help="The text read from the file")此工作流部署成功,當(dāng)我運(yùn)行它時(shí),會(huì)發(fā)生以下情況:該create任務(wù)成功運(yùn)行,并說(shuō)明其輸出:the_blob:  type:    single  uri:    /4u/fe0c7c6326294497dac9-create-0/9c684e85918080341a14478b5f013ee6在任務(wù)之間傳遞 s 的正確方法是什么Types.Blob?我該如何進(jìn)行這項(xiàng)工作?
查看完整描述

1 回答

?
www說(shuō)

TA貢獻(xiàn)1775條經(jīng)驗(yàn) 獲得超8個(gè)贊

我假設(shè)您正在本地沙箱環(huán)境中運(yùn)行它(您正在使用 minio,它是我們?cè)谏诚洵h(huán)境中部署的測(cè)試 blob 存儲(chǔ))。您能否分享您用于注冊(cè)工作流程的 Flytekit.config 文件。

因此,F(xiàn)lyte 根據(jù)您的配置方式自動(dòng)將中間數(shù)據(jù)存儲(chǔ)在存儲(chǔ)桶 (S3 / GCS) 中。

前綴設(shè)置用于自動(dòng)將數(shù)據(jù)上傳到配置的存儲(chǔ)桶和前綴 https://github.com/lyft/flytesnacks/blob/b980963e48eac4ab7e4a9a3e58b353ad523cee47/cookbook/sandbox.config#L7

v0.7.0 之前的版本 - 使用配置中的分片格式化程序設(shè)置 - https://github.com/lyft/flytesnacks/blob/b980963e48eac4ab7e4a9a3e58b353ad523cee47/cookbook/sandbox.config#L14-L17

另請(qǐng)告訴我們您正在運(yùn)行的 Flyte 版本。請(qǐng)加入 Slack 頻道,我可以幫助您入門。抱歉給大家?guī)?lái)的麻煩


查看完整回答
反對(duì) 回復(fù) 2023-12-20
  • 1 回答
  • 0 關(guān)注
  • 161 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)