stream读取csv后，csv内容变更后，print出来的内容没有更新

[Emmitte]

大神们好，我有个问题，用CsvSourceStreamOp方法读取csv后，csv内容变更后，print出来的内容没有更新。以下是我的代码，请大神帮忙解决一下，谢谢！
`#!/usr/bin/python

-- coding: UTF-8 --

from pyalink.alink import *
import numpy as np
import pandas as pd

useLocalEnv(1)

schemaStr = "A double, B double, C double, D double, label string"
path = "D:/program/Alink_script/data/iris2_1_stream.csv"
csvSource = CsvSourceStreamOp().setFilePath(path).setSchemaStr(schemaStr).setFieldDelimiter(",")
csvSource.print()
sample = SampleStreamOp().setRatio(0.01).linkFrom(csvSource)
sample.print(key="csvSource", refreshInterval=1)
StreamOperator.execute()`

[chengscu]

大神们好，我有个问题，用CsvSourceStreamOp方法读取csv后，csv内容变更后，print出来的内容没有更新。以下是我的代码，请大神帮忙解决一下，谢谢！
`#!/usr/bin/python

-- coding: UTF-8 --

from pyalink.alink import *
import numpy as np
import pandas as pd

useLocalEnv(1)

schemaStr = "A double, B double, C double, D double, label string"
path = "D:/program/Alink_script/data/iris2_1_stream.csv"
csvSource = CsvSourceStreamOp().setFilePath(path).setSchemaStr(schemaStr).setFieldDelimiter(",")
csvSource.print()
sample = SampleStreamOp().setRatio(0.01).linkFrom(csvSource)
sample.print(key="csvSource", refreshInterval=1)
StreamOperator.execute()`

你好，CSV不会读取新的内容。针对您的这个场景，建议使用消息队列，例如kafka。

[Emmitte]

好嘞，谢谢您！发自我的华为手机-------- 原始邮件 --------主题：Re: [alibaba/Alink] stream读取csv后，csv内容变更后，print出来的内容没有更新 (#9)发件人：Cheng Jie 收件人：alibaba/Alink 抄送：Emmitte ,Author 大神们好，我有个问题，用CsvSourceStreamOp方法读取csv后，csv内容变更后，print出来的内容没有更新。以下是我的代码，请大神帮忙解决一下，谢谢！ `#!/usr/bin/python -- coding: UTF-8 -- from pyalink.alink import * import numpy as np import pandas as pd useLocalEnv(1) schemaStr = "A double, B double, C double, D double, label string" path = "D:/program/Alink_script/data/iris2_1_stream.csv" csvSource = CsvSourceStreamOp().setFilePath(path).setSchemaStr(schemaStr).setFieldDelimiter(",") csvSource.print() sample = SampleStreamOp().setRatio(0.01).linkFrom(csvSource) sample.print(key="csvSource", refreshInterval=1) StreamOperator.execute()` 你好，CSV不会读取新的内容。针对您的这个场景，建议使用消息队列，例如kafka。 —You are receiving this because you authored the thread.Reply to this email directly, view it on GitHub, or unsubscribe. [ { "@context": "http://schema.org", "@type": "EmailMessage", "potentialAction": { "@type": "ViewAction", "target": "#9?email_source=notifications\u0026email_token=ADRV3EN27P27BHGMEVE5SMLQWYPWXA5CNFSM4JUURF42YY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOEFYUY2A#issuecomment-561073256", "url": "#9?email_source=notifications\u0026email_token=ADRV3EN27P27BHGMEVE5SMLQWYPWXA5CNFSM4JUURF42YY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOEFYUY2A#issuecomment-561073256", "name": "View Issue" }, "description": "View this Issue on GitHub", "publisher": { "@type": "Organization", "name": "GitHub", "url": "https://github.com" } } ]