Skip to content

Instantly share code, notes, and snippets.

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
KAFKA_TOPIC_DOCUMENT_PERSIST_IN:
ai.flowx.in.document.persist.v1
KAFKA_TOPIC_DOCUMENT_PERSIST_OUT:
ai.flowx.updates.document.persist.v1
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});
}
// connector 1
"In": [
{
"Name": "ai.flowx.connectordb2.workshop.in.v1", // changed
"Partitions": 1,
"ReplicationFactor": 1,
"ProcessingThreads": 1,
"WorkerThreads": 2
}
],
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/
[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
laur3d / FlowMaker-LowCode.cs
Created April 28, 2021 07:56
Dynamic Workflows Low Code Style
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
laur3d / DynamicOrchestrator.cs
Last active April 15, 2021 06:55
Dynamic Orchestrator
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>>
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();
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();