如何在 Rhino ETL DSL 中使用 FluentFile？

Question

我一直在研究 Rhino ETL 库，并且非常喜欢它的发展方向。 然而，我发现它的缺点是文档很少，并且似乎没有足够的关于如何创建这些管道流程（尤其是使用 DSL）的好信息。

我只是尝试创建一个 DSL 文件来加载文件并将数据导出到另一个文件中，看看这一切如何组合在一起。 到目前为止我所拥有的是这个。

[DelimitedRecord("\t")]
class User:
  public Name as string
  public Phone as string
  public Email as string

operation import_file:
  file = Rhino.Etl.Core.Files.FluentFile(typeof(User)).From("""E:\Fake\Book1.txt""")
  for row in file:
    yield Row.FromObject(row)

operation export_file:
  file = Rhino.Etl.Core.Files.FluentFile(typeof(User)).To("""E:\Fake\Test.txt""")
  for row in rows:
    record = User(Name: row["Name"])
    file.Write(record)

process ImportFile:
  import_file()
  export_file()

它抛出此异常

File.boo(1,2): BCE0064: Boo.Lang.Compiler.CompilerError: 找不到名称为“DelimitedRecord”或“DelimitedRecordAttribute”的属性（属性名称不区分大小写）。 您的意思是 'System.Diagnostics.DelimitedListTraceListener' 吗？

如果我删除属性部分，则会收到此错误

异常：无法创建管道导入文件：用户类必须使用 [DelimitedRecord] 或 [FixedLengthRecord] 属性进行标记。 异常：无法执行 File.import_file 操作：类 User 必须使用 [DelimitedRecord] 或 [FixedLengthRecord] 属性进行标记。

这里有什么想法吗？ 或者有没有关于如何在 DSL 中使用 FluentFile 进行 Rhino ETL 的示例？

Answer 1

DelimitedRecordAttribute 位于FileHelpers 程序集，FileHelpers 命名空间。