laur3d

kafka topics:

        - name: KAFKA_TOPIC_DOCUMENT_GENERATE_HTML_IN
          value: ai.flowx.in.document.html.generate.v1
        - name: KAFKA_TOPIC_DOCUMENT_GENERATE_HTML_OUT
          value: ai.flowx.updates.document.html.generate.v1
        - name: KAFKA_TOPIC_DOCUMENT_GENERATE_PDF_IN
          value: ai.flowx.in.document.generate.v1
        - name: KAFKA_TOPIC_DOCUMENT_GENERATE_PDF_OUT
          value: ai.flowx.updates.document.generate.v1

laur3d

KAFKA_TOPIC_DOCUMENT_PERSIST_IN:
ai.flowx.in.document.persist.v1
KAFKA_TOPIC_DOCUMENT_PERSIST_OUT:
ai.flowx.updates.document.persist.v1

laur3d

ai.flowx.updates.document.persist.v1 <-- topic from doc plugin

uploadedDocument <-- key 

MVEL

if(input.uploadedDocument.downloadPath!=null){
    output.put("app",{"uploadedDocument": "https://admin-laur.playground.flowxai.dev/document/" + input.uploadedDocument.downloadPath});
}

laur3d

// connector 1
    "In": [
      {
        "Name": "ai.flowx.connectordb2.workshop.in.v1", // changed
        "Partitions": 1,
        "ReplicationFactor": 1,
        "ProcessingThreads": 1,
        "WorkerThreads": 2
      }
    ],

laur3d

De urcat ca si proces:
https://designer-workshop.playground.flowxai.dev/processes/definitions/109001/diagram?nodeId=109053&edit=true&templateId=313884
https://designer-workshop.playground.flowxai.dev/processes/definitions/110754/diagram?nodeId=113180
De descarcat si urcat ca si media library.
https://d2l8u5oe5161s.cloudfront.net/training/flowx/CheckCircle/1696411455444_CheckCircle.svg
https://d177l48o9taai0.cloudfront.net/demo-22/flowx/RequestedAmountBackground/1693478433943_requestedAmountBackground.png
https://d177l48o9taai0.cloudfront.net/demo-22/flowx/whiteCircle/1689940848517_whiteCircle.png


https://kubernetes.io/docs/reference/kubectl/cheatsheet/

laur3d

[FunctionName("DynamicOrchestrator")]
public static async Task<DynamicResult<int>> RunInnerOrchestrator([OrchestrationTrigger] IDurableOrchestrationContext ctx)
{
    var input = ctx.GetInput<DynamicFlowContext>();
    int state = 0;
 
    foreach (var step in input.Steps)
    {
        state = await ctx.CallActivityAsync<int>(step.Action, (state, step.param));
    }

laur3d

namespace dynamicworkflows.Workflows
{
    using Jint;
    using Newtonsoft.Json;
    using System.Collections.Generic;
    using System.Net.Http;
    using System.Threading.Tasks;
    using Microsoft.Azure.WebJobs;
    using Microsoft.Azure.WebJobs.Extensions.DurableTask;
    using Microsoft.Azure.WebJobs.Extensions.Http;

laur3d

   public static class FlowMaker
    {
        [FunctionName("FlowMaker")]
        public static async Task<int> Run([OrchestrationTrigger] IDurableOrchestrationContext context)
        {

            // imagine this comes from a DB or the request payload
            var steps = new DynamicFlowContext
            {
                Steps = new List<DynamicStep<int>>

laur3d

class Solution
{
    static void Main()
    {
        int L = int.Parse(Console.ReadLine());
        int H = int.Parse(Console.ReadLine());
        string Sentence = Console.ReadLine().ToUpper();
        
        for (int i = 0; i < H; i++) {
            string AsciiRow = Console.ReadLine();

laur3d

class Solution
{
    static void Main(string[] args)
    {
        int L = int.Parse(Console.ReadLine());
        int H = int.Parse(Console.ReadLine());
         
        var writter = new Writer(H,L);
         
        string T = Console.ReadLine();