Skip to content

Instantly share code, notes, and snippets.

@baybatu

baybatu/nifi-test-el.groovy

Created September 29, 2021 19:10
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save baybatu/c3c0cbe3201427f279047977d4fc09fd to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save baybatu/c3c0cbe3201427f279047977d4fc09fd to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. baybatu created this gist Sep 29, 2021.
    29 changes: 29 additions & 0 deletions nifi-test-el.groovy
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,29 @@
    // usage: groovy nifi-test-el.groovy '${now():toNumber():minus(3999900000):format("yyyy-MM-dd HH:mm:ss", "GMT")}'
    // source: https://community.cloudera.com/t5/Community-Articles/Testing-NiFi-Expression-Language-with-Groovy/ta-p/247208
    @Grab(group='org.apache.nifi', module='nifi-expression-language', version='1.4.0')
    import org.apache.nifi.attribute.expression.language.*

    def cli = new CliBuilder(usage:'groovy testEL.groovy [options] [expressions]',
    header:'Options:')
    cli.help('print this message')
    cli.D(args:2, valueSeparator:'=', argName:'attribute=value',
    'set value for given attribute')
    def options = cli.parse(args)
    if(!options.arguments()) {
    cli.usage()
    return 1
    }

    def attrMap = [:]
    def currKey = null
    options.Ds?.eachWithIndex {o,i ->
    if(i%2==0) {
    currKey = o
    } else {
    attrMap[currKey] = o
    }
    }
    options.arguments()?.each {
    def q = Query.compile(it)
    println q.evaluate(attrMap ?: null)
    }