Ниже приведён пример использования операции SetEtl для добавления в задачу ETL источника репозитория. В запросе передается моникёр открытого экземпляра задачи ETL и параметры создания нового объекта: тип создаваемого объекта и его специфические настройки. В ответе приходит информация о созданном объекте и список его полей, который заполняется на основании структуры таблицы, выступающей в качестве источника данных.
{
"SetEtl" :
{
"tEtl" :
{
"id" : "S1!M!S!L1"
},
"tArg" :
{
"pattern" :
{
"obInst" : "true",
"objects" : "Add",
"object" :
{
"settings" : "true",
"provider" :
{
"props" : "true"
}
}
},
"meta" :
{
"objects" :
{
"its" :
{
"it" :
[
{
"k" : "0",
"id" : "REPO_PROVIDER",
"vis" : "true",
"type" : "PlainDataMetabaseProvider",
"settings" :
{
"plainProvider" :
{
"provider" :
{
"props" :
{
"type" : "Mb",
"mb" :
{
"dataset" :
{
"i" : "T_INDICATOR",
"n" : "Таблица",
"k" : "7013",
"c" : "769"
}
}
}
},
"fillFields" : "FromSource"
}
}
}
]
}
}
},
"metaGet" :
{
"obInst" : "true",
"objects" : "Get",
"objectsFilter" :
{
"range" :
{
"start" : "3",
"count" : "1"
}
},
"object" :
{
"settings" : "true",
"provider" :
{
"fields" : "true"
},
"fields" : "Get"
}
}
}
}
}
{
"SetEtlResult" :
{
"id" :
{
"id" : "S1!M!S!L1"
},
"meta" :
{
"obInst" :
{
"obDesc" :
{
"@ds" : "",
"@isShortcut" : "0",
"@isLink" : "0",
"@ver" : "3",
"@hf" : "0",
"i" : "ETL_INDICATOR",
"n" : "Задача ETL для загрузки показателей",
"k" : "7012",
"c" : "4097",
"p" : "7011",
"h" : "0",
"hasPrv" : "0",
"ic" : "0",
"isPermanent" : "1",
"isTemp" : "0"
}
},
"dirty" : "1",
"objects" :
{
"its" :
{
"it" :
[
{
"k" : "3",
"id" : "REPO_PROVIDER",
"n" : "Источник репозитория1",
"vis" : "1",
"type" : "PlainDataMetabaseProvider",
"obDesc" :
{
"@ds" : "",
"@isShortcut" : "0",
"@isLink" : "0",
"@ver" : "0",
"@hf" : "0",
"i" : "T_INDICATOR",
"n" : "Таблица",
"k" : "7013",
"c" : "769",
"p" : "7011",
"h" : "0",
"hasPrv" : "0",
"ic" : "0"
},
"read" : "1",
"write" : "1",
"settings" :
{
"plainProvider" :
{
"provider" :
{
"fields" :
{
"its" :
{
"it" :
[
{
"k" : "1",
"id" : "FKEY",
"n" : "FKey",
"vis" : "1",
"dt" : "2",
"dd" : "0",
"size" : "10",
"precision" : "0",
"expression" : "",
"calculated" : "0",
"dateFormat" : "ДМГ"
},
{
"k" : "2",
"id" : "FNAME",
"n" : "FName",
"vis" : "1",
"dt" : "1",
"dd" : "0",
"size" : "255",
"precision" : "0",
"expression" : "",
"calculated" : "0",
"dateFormat" : "ДМГ"
},
{
"k" : "3",
"id" : "ORD",
"n" : "Ord",
"vis" : "1",
"dt" : "2",
"dd" : "0",
"size" : "10",
"precision" : "0",
"expression" : "",
"calculated" : "0",
"dateFormat" : "ДМГ"
},
{
"k" : "4",
"id" : "FID",
"n" : "FId",
"vis" : "1",
"dt" : "1",
"dd" : "0",
"size" : "255",
"precision" : "0",
"expression" : "",
"calculated" : "0",
"dateFormat" : "ДМГ"
}
]
}
}
},
"fetchBlockSize" : "-1",
"ignoreIncorrectVals" : "0",
"unpivotMode" : "0"
}
}
}
]
}
},
"shapes" : ""
}
}
}
public static SetEtlResult AddProvider(MbId mb, EtlId moniker, string providerId)
{
var somClient = new SomPortTypeClient(); //Прокси-объект для выполнения операций
var providerDesc = FindObjectById(mb, providerId); // Описание источника
//Параметры выполнения операции
var tSet = new SetEtl()
{
tArg = new SetEtlArg()
{
pattern = new EtlMdPattern()
{
objects = ListOperation.Add,
@object = new EtlObjectPattern()
{
settings = true,
provider = new EtlProviderPattern()
{
props = true
}
}
},
meta = new EtlMd()
{
objects = new EtlObjects()
{
its = new EtlObject[]
{
new EtlObject()
{
//Базовые свойства
id = "REPO_PROVIDER",
k = 0,
type = EtlObjectType.PlainDataMetabaseProvider,
vis = true,
//Настройка источника
settings = new EtlObjectSettings()
{
plainProvider = new EtlPlainDataProvider()
{
fillFields = EtlFillFieldsType.FromSource,
provider = new DtProviderMd()
{
props = new DtProviderProps()
{
type = DtProviderType.Mb,
mb = new DtProviderMb()
{
dataset = new Ob()
{
k = providerDesc.k,
i = providerDesc.i,
c = providerDesc.c,
n = providerDesc.n
}
}
}
}
}
}
}
}
}
},
metaGet = new EtlMdPattern()
{
objects = ListOperation.Get,
objectsFilter = new ListFilter() { range = new ListRange() {start = 3, count = 1}},
@object = new EtlObjectPattern()
{
fields = ListOperation.Get,
settings = true,
provider = new EtlProviderPattern() {fields = true}
}
}
},
tEtl = moniker
};
//Добавление объекта в задачу ETL
var result = somClient.SetEtl(tSet);
return result;
}
См. также: