010
IN Migration Kafka концепт
011
012
Каким образом производиться миграций через кафку?
013
014
Миграция через кафку производиться таким способом, что в кафке
015 создаётся топик с каким-то названием которого не встречается в
016 кафке на данный момент, далее в этот топик скидываются данные
017 различных Бизнес Объектов(БО) в виде строк, которые содержит в себе
018 JSON определенного ниже описанного формата, дальше этот топик
019 регистрируется в системе и после регистраций в системе, система
020 обращается в данный топик и начинает загружать данные в себе базу
021 данных.
022
023
Здесь описано
024 это детальней.
025
026
Структура JSON, каким оно должно быть.
027
028
Структура JSON должен соответствовать ниже приведённому
029 примеру.
030
031
032 {
033 "recordId": "12345",
034 "externalId": "bfsseVCjGC225bM@",
035 "id": "dgL9~4keReK7Z1qi",
036 "boCode": "BO",
037 "fields": [
038 {
039 "code": "textField",
040 "apiValue": "someValue"
041 },
042 {
043 "code": "textField2",
044 "apiValue": "someValue2"
045 }
046 ],
047 "boFields": [
048 {
049 "fieldCode": "boTextField",
050 "toBoCode": "BO2",
051 "toFieldCode": "textFieldOfBO2",
052 "apiValue": "015252634519"
053 },
054 {
055 "fieldCode": "boTextField",
056 "boiInput": {
057 "recordId": "12345",
058 "externalId": "bfsseVCjGC225bM@",
059 "id": "dgL9~4keReK7Z1qi",
060 "boCode": "BO",
061 "fields": [
062 {
063 "code": "textField",
064 "apiValue": "someValue"
065 },
066 {
067 "code": "textField2",
068 "apiValue": "someValue2"
069 }
070 ],
071 "boFields": {...}
072 }
073 }
074 ],
075 "state": "ACTUAL"
076 }
077
078
079
080
081
082
083
Подробнее о полях
084
085
086 recordId:Строка - Идентификатор данной записи, он должен быть уникальным в рамках всего топика
087 он используется для того чтобы запись обрабатывалась всего одни раз его затем,
088 система его запоминает и при повторной записи система его игнорирует.
089
090 id:Строка - Идентификатор инстанции бизнес-объекта внутренний для платформы MyBPM. Если он указан, то
091 ищется запись по этому идентификатору. Если находиться, то происходит обновление данных.
092 Иначе генерируется ошибка. Если этот идентификатор не указан, то используется идентификатор
093 externalId
094
095 externalId:Строка - Идентификатор инстанции БО, который используется во внешней системе (которая поставляет данные).
096 Если внутренний идентификатор не используется, то используется данный идентификатор для поиска
097 инстанции. В таком случае если инстанция находиться, то происходит обновление данных. Если не
098 находиться, то создаётся новая инстанция.
099
100 boCode:Строка - Код бизнес объекта в которой, должны записаться данные.
101
102 fields:Массив - Поля со значениями для мигрированния .
103 code:Строка - Код поля в бизнес объекте .
104 apiValue:Строка - Значение из REST API.
105
106 boFields:Массив - Бизнес-поля для миграции вложенных бизнес-объектов
107 Стандартный подход:{
108 fieldCode:Строка - Код поля, который принадлежит с кодом boCode.
109 toBoCode:Строка - Код бизнес объекта на которое указывает данное поле.
110 toFieldCode:Строка - Код поля у бизнес объекта toBoCode. Это поле должно быть уникальное
111 apiValue:Строка - Значение поле toFieldCode у бизнес объекта с кодом toBoCode.
112 }
113 Рекурсивный подход:{
114 fieldCode:Строка - Код поля, который принадлежит с кодом boCode.
115 boiInput:Строка - вложенный JSON другого BoiInput.
116 }
117
118 state - Состояние записи могут быть (ACTUAL, REMOVED, ARCHIVED, TEST), может отсутствовать,
119 если записи нету то state станет ACTUAL, а если запись есть то ничего не измениться
120 ACTUAL:Строка - Это актуальная запись которая доступна для работы.
121 REMOVED:Строка - Удалённая запись.
122 ARCHIVED:Строка - Архивированная запись.
123 TEST:Строка - Запись предназначена для режима тестирования
124
125
126
127
128
129
137