Azure Cosmos DB-dokumentumok feldolgozása és létrehozása az Azure Logic Apps használatával
A következőkre vonatkozik: Azure Logic Apps (Használat + Standard)
Az Azure Logic Apps munkafolyamatából csatlakozhat az Azure Cosmos DB-hez, és az Azure Cosmos DB-összekötő használatával dolgozhat dokumentumokkal. Ez az összekötő olyan eseményindítókat és műveleteket biztosít, amelyeket a munkafolyamat az Azure Cosmos DB-műveletekhez használhat. A műveletek közé tartozik például a dokumentumok létrehozása vagy frissítése, olvasása, lekérdezése és törlése.
Az Azure Cosmos DB-hez mind a Logic App (Használat), mind a Logic App (Standard) erőforrástípusból csatlakozhat a felügyelt összekötő műveleteinek használatával. A Logic App (Standard) esetében az Azure Cosmos DB beépített műveleteket is biztosít, amelyek jelenleg előzetes verzióban érhetők el, és különböző funkciókat, jobb teljesítményt és nagyobb átviteli sebességet kínálnak. Ha például a Logic App (Standard) erőforrástípussal dolgozik, a beépített eseményindítóval reagálhat egy Azure Cosmos DB-tároló változásaira. Az Azure Cosmos DB-műveleteket kombinálhatja más műveletekkel és eseményindítókkal a logikai alkalmazás munkafolyamataiban, hogy olyan forgatókönyveket engedélyezhessen, mint az esemény-beszerzés és az általános adatfeldolgozás.
Korlátozások
Jelenleg csak a Logikai alkalmazás (Standard) erőforrás állapotalapú munkafolyamatai használhatják a felügyelt összekötő műveleteit és a beépített műveleteket. Az állapot nélküli munkafolyamatok csak beépített műveleteket használhatnak.
Az Azure Cosmos DB-összekötő csak az Azure Cosmos DB for NoSQL-hez létrehozott Azure Cosmos DB-fiókokat támogatja.
Előfeltételek
Azure-fiók és -előfizetés. Ha nem rendelkezik Azure-előfizetéssel, regisztráljon egy ingyenes Azure-fiókra.
Egy Azure Cosmos DB-fiók.
Egy logikai alkalmazás munkafolyamata, amelyből hozzá szeretne férni az Azure Cosmos DB-fiókjához. Az Azure Cosmos DB-eseményindító használatához létre kell hoznia a logikai alkalmazást a Logic App (Standard) erőforrástípussal, és hozzá kell adnia egy üres munkafolyamatot.
Azure Cosmos DB-eseményindító hozzáadása
Az Azure Logic Appsben minden munkafolyamatnak egy eseményindítóval kell kezdődnie, amely egy adott esemény bekövetkezésekor vagy egy adott feltétel teljesülésekor aktiválódik.
Ha a Logic App (Standard) erőforrástípussal dolgozik, az elem létrehozása vagy módosítása (előzetes verzió) nevű beépített eseményindító elérhető, és az Azure Cosmos DB változáscsatorna-mintáján alapul. Ez az eseményindító nem érhető el a Logic App (Consumption) erőforrástípushoz.
A Logic App (Consumption) erőforrástípushoz nem érhetők el Azure Cosmos DB-eseményindítók.
Azure Cosmos DB-művelet hozzáadása
Az Azure Logic Appsben a művelet a munkafolyamat egy olyan lépése, amely egy eseményindítót vagy egy másik műveletet követ. Az Azure Cosmos DB-összekötő a Logic App (Használat) és a Logic App (Standard) erőforrástípusokhoz egyaránt kínál műveleteket. Az egyes erőforrástípusokra vonatkozó alábbi példák bemutatják, hogyan használható egy dokumentumot létrehozó vagy módosító művelet.
Ha Azure Cosmos DB-műveletet szeretne hozzáadni egy több-bérlős Azure Logic Apps logikai alkalmazás munkafolyamatához, kövesse az alábbi lépéseket:
Az Azure Portalon nyissa meg a munkafolyamatot a tervezőben.
Ha a munkafolyamat üres, adja hozzá a kívánt eseményindítót.
Ez a példa a HTTP-kérés fogadásának eseményindítójával kezdődik.
Az eseményindító vagy művelet alatt, ahol hozzá szeretné adni az Azure Cosmos DB-műveletet, válassza az Új lépés vagy Művelet hozzáadása lehetőséget, ha a lépések között.
A tervező keresőmezőbe írja be a következőt
Azure Cosmos DB
: Válassza ki a használni kívánt Azure Cosmos DB-műveletet.Ez a példa a Dokumentum létrehozása vagy frissítése (V3) nevű műveletet használja.
Ha a rendszer kéri a kapcsolat részleteit, hozzon létre egy kapcsolatot az Azure Cosmos DB-fiókjával.
Adja meg a művelethez szükséges információkat.
Tulajdonság Kötelező Érték Leírás Azure Cosmos DB-fiók neve Igen Válassza a Kapcsolatbeállítások használata (<Azure-Cosmos-DB-account-name>) lehetőséget, vagy manuálisan adja meg a nevet. Az Azure Cosmos DB-fiók fiókneve. Adatbázis-azonosító Igen <adatbázis-azonosító> A csatlakoztatni kívánt adatbázis. Tároló azonosítója Igen <tárolóazonosító> A lekérdezni kívánt tároló. Dokumentum Igen <JSON-dokumentum> A létrehozni kívánt JSON-dokumentum. Ez a példa az eseményindító kimenetéből származó kérelemtörzset használja. Tipp: Ha a HTTP-eseményindító Törzs jogkivonata nem jelenik meg a hozzáadni kívánt dinamikus tartalomlistában, az eseményindító neve mellett válassza a Továbbiak lehetőséget.
Megjegyzés: Győződjön meg arról, hogy a törzs jól formázott JSON, és legalább tartalmazza a
id
dokumentum tulajdonságát és partíciókulcs-tulajdonságát. Ha a megadottid
és partíciókulcsú dokumentum már létezik, a dokumentum frissül. Ellenkező esetben egy új dokumentum jön létre.Az alábbi képen egy példaművelet látható:
Szükség szerint konfigurálja az egyéb műveleti beállításokat.
A tervező eszköztárán válassza a Mentés lehetőséget.
Tesztelje a logikai alkalmazást, és győződjön meg arról, hogy a munkafolyamat létrehoz egy dokumentumot a megadott tárolóban.
Csatlakozás az Azure Cosmos DB-hez
Amikor olyan eseményindítót vagy műveletet ad hozzá, amely egy szolgáltatáshoz vagy rendszerhez csatlakozik, és nincs meglévő vagy aktív kapcsolata, az Azure Logic Apps kéri, hogy adja meg a kapcsolati adatokat, amelyek a kapcsolat típusától függően változnak, például:
- A fiók hitelesítő adatai
- A kapcsolathoz használandó név
- A kiszolgáló vagy a rendszer neve
- A használni kívánt hitelesítési típus
- Egy kapcsolati sztring
Mielőtt konfigurálhatja az Azure Cosmos DB-eseményindítót vagy az Azure Cosmos DB-műveletet, csatlakoznia kell egy adatbázisfiókhoz.
Egy logikai alkalmazás (használat) munkafolyamatában az Azure Cosmos DB-kapcsolathoz a következő tulajdonságértékek szükségesek:
Tulajdonság | Kötelező | Érték | Leírás |
---|---|---|---|
Kapcsolat neve | Igen | <kapcsolat neve> | A kapcsolathoz használandó név. |
Hitelesítés típusa | Igen | <kapcsolattípus> | A használni kívánt hitelesítési típus. Ez a példa Access-kulcsot használ. – Ha az Access-kulcsot választja, adja meg a kapcsolat létrehozásához szükséges többi tulajdonságértéket. – Ha az integrált Microsoft Entra lehetőséget választja, nincs szükség más tulajdonságértékekre, de konfigurálnia kell a kapcsolatot a Microsoft Entra-hitelesítés és az Azure Cosmos DB-összekötő lépéseinek követésével. |
Hozzáférési kulcs az Azure Cosmos DB-fiókhoz | Igen | <hozzáférési kulcs> | A kapcsolathoz használni kívánt Azure Cosmos DB-fiók hozzáférési kulcsa. Ez az érték írásvédett vagy írásvédett kulcs. Megjegyzés: A kulcs megkereséséhez lépjen az Azure Cosmos DB-fiók lapjára. A navigációs menü Beállítások csoportjában válassza a Kulcsok lehetőséget. Másolja ki a rendelkezésre álló kulcsértékek egyikét. |
Fiókazonosító | Igen | <acccount-ID> | A kapcsolathoz használandó Azure Cosmos DB-fiók neve. |
Az alábbi képen egy példakapcsolat látható:
Feljegyzés
A kapcsolat létrehozása után, ha más meglévő Azure Cosmos DB-kapcsolattal rendelkezik, amelyet inkább használni szeretne, vagy ha új kapcsolatot szeretne létrehozni, válassza a Kapcsolat módosítása lehetőséget az eseményindító vagy a művelet részleteinek szerkesztőjében.
Összekötőkkel kapcsolatos segédlet
Az Azure Cosmos DB által felügyelt összekötőműveletekkel , például eseményindítókkal, műveletekkel és korlátozásokkal kapcsolatos referenciainformációkért tekintse át az összekötő referenciaoldalát.
Nincs megfelelő referencialap az Azure Cosmos DB beépített műveleteihez. Ehelyett tekintse át a következő táblázatot további információkért:
Típus | Név | Paraméterek |
---|---|---|
Eseményindító | Elem létrehozásakor vagy módosításakor | - Adatbázis-azonosító: Kötelező. Az adatbázis neve a figyelt és a bérletes tárolókkal. - Monitorozott tárolóazonosító: Kötelező. A figyelt tároló neve. - Bérlettároló azonosítója: Kötelező. A bérletek tárolására használt tároló neve. - Bérlettároló létrehozása: Kötelező. Ha igaz, hozza létre a bérlettárolót, ha még nem létezik. - Tároló átviteli sebességének bérlete: Nem kötelező. A bérlettároló létrehozásakor hozzárendelni kívánt kérelemegységek száma. |
Művelet | Elem létrehozása vagy frissítése | - Adatbázis-azonosító: Kötelező. Az adatbázis neve. - Tárolóazonosító: Kötelező. A tároló neve. - Elem: Kötelező. A létrehozni vagy frissíteni kívánt elem. - Partíciókulcs: Nem kötelező. A kért elem partíciókulcs-értéke. - Is Upsert: Nem kötelező. Ha igaz, cserélje le az elemet, ha van. Ellenkező esetben hozza létre az elemet. |
Művelet | Több elem tömeges létrehozása vagy frissítése | Ez a művelet nagy átviteli sebességű forgatókönyvekhez van optimalizálva, és további feldolgozással rendelkezik, mielőtt a művelet elküldené a létrehozandó elemeket az Azure Cosmos DB-tárolóban. Nagy mennyiségű elem esetén ez a további feldolgozás felgyorsítja a kérelem teljes idejét. Kis számú elem esetén ez a többletterhelés lassabb teljesítményt okozhat, mint több önálló létrehozási elemművelet használata. - Adatbázis-azonosító: Kötelező. Az adatbázis neve. |
Művelet | Elem olvasása | - Adatbázis-azonosító: Kötelező. Az adatbázis neve. - Tárolóazonosító: Kötelező. A tároló neve. - Elemazonosító: Kötelező. A id kért elem értéke. - Partíciókulcs: Kötelező. A kért elem partíciókulcs-értéke. |
Művelet | Elem törlése | - Adatbázis-azonosító: Kötelező. Az adatbázis neve. - Kötelező a tárolóazonosító . A tároló neve. - Elemazonosító: Kötelező. A id kért elem értéke. - Partíciókulcs: Kötelező. A kért elem partíciókulcs-értéke. |
Művelet | Lekérdezési elemek | - Adatbázis-azonosító: Kötelező. Az adatbázis neve. - Tárolóazonosító: Kötelező. A tároló neve. - Sql-lekérdezés: Kötelező. Az Azure Cosmos DB SQL-lekérdezés szövege. - Partíciókulcs: Nem kötelező. A kérés partíciókulcs-értéke, ha van ilyen. - Folytatási jogkivonat: Nem kötelező. Az Azure Cosmos DB szolgáltatás által adott lekérdezéshez tartozó folytatási jogkivonat, ha van ilyen. - Maximális elemszám: Nem kötelező. A lekérdezés visszaadandó elemeinek maximális száma. |
Ajánlott eljárások az Azure Cosmos DB beépített műveleteihez
Iterable eredmények lekérése a Lekérdezéselemek műveletből
A Logikai alkalmazás (Standard) munkafolyamat beépített Lekérdezéselemek művelete számos dinamikus tartalomkimenettel rendelkezik, amelyek a későbbi műveletekhez használhatók. A lekérdezés eredményelemeinek vagy az elem metaadatainak iterálható objektumként való lekéréséhez kövesse az alábbi lépéseket:
Az Azure Portalon nyissa meg a munkafolyamatot a tervezőben.
Ha a munkafolyamat üres, adja hozzá a kívánt eseményindítót.
Ez a példa az Ismétlődés eseményindítóval kezdődik.
Az eseményindító vagy művelet alatt, ahol hozzá szeretné adni az Azure Cosmos DB-műveletet, válassza az Új lépés beszúrása (+) >Művelet hozzáadása lehetőséget.
A tervezőn győződjön meg arról, hogy a Művelet hozzáadása lehetőség van kiválasztva. A megnyíló Művelet hozzáadása panelEn, a Művelet kiválasztása keresőmezőben válassza a Beépített elemet az Azure Cosmos DB-műveletek megkereséséhez.
A keresőmezőbe írja be a
Azure Cosmos DB
kifejezést. Válassza ki a Lekérdezéselemek (előzetes verzió) műveletet.Ha a rendszer kéri a kapcsolat részleteit, hozzon létre egy kapcsolatot az Azure Cosmos DB-fiókjával.
Adja meg a művelethez szükséges információkat.
Tulajdonságok Kötelező Érték Leírás Adatbázis-azonosító Igen <adatbázis-azonosító> A csatlakoztatni kívánt adatbázis. Tárolóazonosító Igen <tárolóazonosító> A lekérdezni kívánt tároló. SQL-lekérdezés Igen <sql-query> A kérés SQL-lekérdezése. Az alábbi képen egy példaművelet látható:
Szükség szerint konfigurálja az egyéb műveleti beállításokat.
A művelet alatt válassza az Új lépés beszúrása (+) >Művelet hozzáadása lehetőséget. A megnyíló Művelet hozzáadása panelen válassza ki az összes lekérdezési eredményelemen futtatni kívánt műveletet.
Ez a példa az Azure Cosmos DB Egy elem törlése (előzetes verzió) nevű beépített műveletét használja.
- A korábban hozzáadott műveletben a lekérdezési művelet kimenetéből érheti el az adatokat. Kattintson a művelet bármelyik beviteli mezőjébe, hogy megjelenjen a dinamikus tartalomlista. Válassza ki az elérhető válaszelemek bármelyikét, vagy válassza a Továbbiak megtekintése lehetőséget a további lehetőségekért.
Ez a példa az Elemazonosító mező válaszelem-azonosítójával tölti ki az azonosítókat a lekérdezés eredményei alapján.
Miután kiválasztott egy válaszelemet, a program automatikusan hozzáadja az Egyes műveletekhez az iterációt az összes lekérdezési eredményen keresztül. Az Egyes ciklusok esetében a korábban hozzáadott műveletet tartalmazza. Hozzáadhat minden más műveletet, amelyet a ciklushoz szeretne adni.
A tervező eszköztárán válassza a Mentés lehetőséget.
Tesztelje a logikai alkalmazást, és győződjön meg arról, hogy a munkafolyamat a várt kimenetet adja vissza.