Обработка данных журнала веб-сервера и использование Kafka для обмена сообщениями и K SQL для обработки - PullRequest
0 голосов
/ 13 марта 2020

Я пытаюсь найти положение подстроки из основной строки, но я не получил никакой функции в K sql db, может кто-нибудь предложить мне любую функцию, чтобы найти положение.

3/11/20 1:32:02 PM CDT, 00005, {"value":" 472 Dynamic 11 SQL 0 Start=2020/03/11 05:51:05.730 MOdelName: SELECT DISTINCT "TIME_DIM".YEAR_DESC, "TIME_DIM".LEVEL1_KEY FROM "TEST_TIME_DIM" WHERE (("TIME_DIM".HIER_FLAG_TEST = 59) AND ("TIME_DIM".LEVEL1_KEY = "TIME_DIM".UNIFORM_KEY_TEST) AND ("TIME_DIM".LEVEL2_KEY_TEST IS NULL) AND ("TIME_DIM".LEVEL3_KEY_TEST IS NULL) AND ("TIME_DIM".LEVEL5_KEY_TEST IS NULL)) ORDER BY "TIME_DIM".YEAR_DESC_TEST ASC, "TIME_DIM".LEVEL1_KEY_TEST ASC [nodeid=1]"}

в вышеприведенном сообщении я хочу извлечь все sql и пытаюсь найти позицию символа "SQL", чтобы на основе позиции я мог извлечь sql.

...