.NET 開発基盤部会 Wiki」は、「Open棟梁Project」,「OSSコンソーシアム .NET開発基盤部会」によって運営されています。

目次

概要

Apache NiFi?のRDBMS系のProcessor

詳細

参照系

  • ExecuteSQL
  • QueryDatabaseTable?

更新系

  • PutSQL
    参照以外の更新系SQLを実行する。

パラメタライズ

パラメタライズするには、

  • NiFi? Expression Language(EL)
  • 若しくは、sql.args.N.value, sql.args.N.type

を使用するが、SQL Injection対策には後者が必要。
だた、後者は難しいので、ConvertJSONToSQLを使用して、属性やSQLを確認すると良い。

SQL生成

  • ConvertJSONToSQL
    • JSONとTable間のアダプタのようなもの。
    • ContentにはSQLを設定する。
      DELETE FROM Shippers WHERE ShipperID = ? AND CompanyName = ? AND Phone = ?
    • Attributeにはパラメタを設定する。
      {
        "sql.table":"Shippers",
        "sql.args.1.value":"1",
        "sql.args.1.type":"4",
        "sql.args.2.type":"-9",
        "sql.args.2.value":"hoge",
        "sql.args.3.type":"-9",
        "sql.args.3.value":"hogehoge"
      }

Avro

レコードの値のデータ・スキーマを定義する。
ExecuteSQLの結果は、Avro形式で入力される。

  • SplitAvro?
  • ConvertAvroToJSON
  • ConvertAvroToORC
  • ConvertCSVToAvro?
  • ConvertJSONToAvro?
  • ExtractAvroMetadata?
  • InferAvroSchema?
  • ConvertAvroSchema?

その他

  • ListDatabaseTables?
  • CaptureChangeMySQL

参考

Hortonworks


添付ファイル: fileSQLFromJSON.xml 36件 [詳細]

トップ   編集 凍結 差分 バックアップ 添付 複製 名前変更 リロード   新規 一覧 単語検索 最終更新   ヘルプ   最終更新のRSS
Last-modified: 2018-07-13 (金) 11:00:15 (346d)