diff --git a/lib/NGCP/BulkProcessor/Projects/ETL/Lnp/settings.yml b/lib/NGCP/BulkProcessor/Projects/ETL/Lnp/settings.yml new file mode 100644 index 0000000..5cf97c0 --- /dev/null +++ b/lib/NGCP/BulkProcessor/Projects/ETL/Lnp/settings.yml @@ -0,0 +1,65 @@ + +#dry=0 +#skip_errors=0 + +import_multithreading: 1 +#lnp_import_numofthreads: + +sqlite_db_file: sqlite + +lnp_filename: ip_telekom.txt +#012_20190201233214.txt +#ip_telekom_delete.txt +#test.csv +lnp_rownum_start: 2 +lnp_import_single_row_txn: 0 +ignore_lnp_unique: 0 + +expand_numbers: !!perl/code | + { + my ($context,$row) = @_; + if ($row =~ /^Linha\d+=([^=]*)$/i) { + my ( + $DonorID, + $HolderID, + $TypeOfNumber, + $PABXMainTelephoneNumber, + $FirstTelephoneNumber, + $LastTelephoneNumber, + $PresentNRN, + $DateTimeFrom + ) = split(/,/,$1); + + my @lnp_numbers = (); + #020,012,0,212879000,212879000,212879999,D012001,2016-08-31 14:20:18 + unless ($PresentNRN =~ /^D012[0-9]{3,3}$/) { + foreach my $number ($FirstTelephoneNumber .. $LastTelephoneNumber) { + push(@lnp_numbers,[ + $PresentNRN, #'carrier_name', + $PresentNRN, #'carrier_prefix', + $number, #'number', + undef, #'routing_number', + $DateTimeFrom, #'start', + undef, #'end', + undef, #'authoritative', + undef, #'skip_rewrite', + undef, #'type', + ]); + } + } + return \@lnp_numbers; + } + + return []; + } + +create_lnp_multithreading: 1 +#create_lnp_numofthreads: 2 + +delete_lnp_multithreading: 1 +#delete_lnp_numofthreads: 2 + +ignore_lnp_numbers_unique: 0 +lnp_numbers_single_row_txn: 0 + +lnp_numbers_batch_delete: 1 \ No newline at end of file