「.NET 開発基盤部会 Wiki」は、「Open棟梁Project」,「OSSコンソーシアム .NET開発基盤部会」によって運営されています。
目次 †
概要 †
Apache NiFi?のRDBMS系のProcessor
詳細 †
参照系 †
- ExecuteSQL
- QueryDatabaseTable?
更新系 †
パラメタライズ †
パラメタライズするには、
- 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 †
![[PukiWiki]](image/pukiwiki.png "[PukiWiki]")
