Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

Jalur absolut Flowfile Nifi

  • Hentikan PutSQL prosesor dan biarkan flowfile mengantre.
  • Setelah mereka mengantri, klik kanan pada success hubungan
    antara UpdateAttribute dan PutSQL dan pilih List Queue .
  • Pilih salah satu flowfile dan navigasikan ke Attributes tab dan lihat apakah atribut absolute.path dan flowfilename ada dan jika
    mereka memang ada, verifikasi apakah mereka memiliki nilai yang diharapkan. Dalam kasus Anda absolute.path harus memiliki nilai /path/in/nifi/node/to/file dan flowfilename harus memiliki nilai /data.csv

Pertanyaan untuk Anda:Apakah Anda menyetel sendiri atribut ini menggunakan UpdateAttribute , alasannya adalah, NiFi tidak menghasilkan atribut bernama flowfilename , itu menghasilkan satu dengan nama filename .

Satu hal lagi, pastikan salah satu nilai untuk absolute.path diakhiri dengan / di akhir atau nilai flowfilename dimulai dengan / . Jika tidak, mereka akan ditambahkan dan hasilnya akan menjadi /path/in/nifi/node/to/filedata.csv . Anda dapat mencoba append fungsi yang disarankan @Mahendra, jika tidak, Anda cukup menggunakan ${absolute.path}/${flowfilename} .

Perbarui

Saya baru menyadari bahwa absolute.path adalah atribut inti seperti filename , filesize , mime.type , dll. Beberapa prosesor menggunakan semua atribut inti sementara beberapa menggunakan sangat sedikit yang diperlukan. GenerateTableFetch menulis absolute.path tetapi tidak mengatur apa pun untuk itu. Itu sebabnya ia memiliki ./ yang merupakan nilai default.

Jadi saran saya agar pendekatan Anda berhasil adalah, Anda dapat mengatur/menimpa absolute.path secara manual atribut menggunakan UpdateAttribute (sama seperti Anda telah menimpa filename ) dan atur nilai yang diinginkan yaitu /path/in/nifi/node/to/file




  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Memfilter dan Mengelompokkan data dari tabel dengan pasangan kunci/nilai

  2. Kesalahan Tidak Tertangkap:Panggil ke fungsi yang tidak ditentukan mysql_connect ()

  3. Implementasi MySQL dengan CUDA

  4. Bagaimana cara menambahkan gambar ke database php mysql?

  5. Konversi stempel waktu Oracle ke MySQL dalam pernyataan penyisipan MySQL