Как я могу сделать что-то вроде функций/методов языка программирования внутри потока данных? У меня есть потоки данных, которые имеют репликацию последовательности шагов, и мне это не нужно.
Используя язык программирования в качестве примера, что я хочу:
task1;
task2;
insert();
....
task13;
task14;
insert();
....
task60;
task61;
insert();
//insert implementation
insert()
{
logtask;
insertInDatabaseAtask;
insertInDatabaseBtask;
audittask;
}
Я знаю, что возможно разбить мой поток пакетов на большее количество потоков данных, но в некоторых случаях я предпочитаю использовать некоторую модульность, например, методы/функции языка программирования внутри одного и того же потока данных.
Является ли это возможным? Как я могу это сделать?
С уважением, Луис