// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. *** // *** Do not edit by hand unless you're certain you know what you are doing! *** import * as pulumi from "@pulumi/pulumi"; import * as utilities from "./utilities"; /** * Converts a JSON string into a structured JSON object. * * See: https://www.elastic.co/guide/en/elasticsearch/reference/current/json-processor.html * * ## Example Usage * * ```typescript * import * as pulumi from "@pulumi/pulumi"; * import * as elasticstack from "@pulumi/elasticstack"; * * const jsonProc = elasticstack.ElasticsearchIngestProcessorJson({ * field: "string_source", * targetField: "json_target", * }); * const myIngestPipeline = new elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", {processors: [jsonProc.then(jsonProc => jsonProc.json)]}); * ``` */ export function elasticsearchIngestProcessorJson(args: ElasticsearchIngestProcessorJsonArgs, opts?: pulumi.InvokeOptions): Promise { if (!opts) { opts = {} } opts = pulumi.mergeOptions(utilities.resourceOptsDefaults(), opts); return pulumi.runtime.invoke("elasticstack:index/elasticsearchIngestProcessorJson:ElasticsearchIngestProcessorJson", { "addToRoot": args.addToRoot, "addToRootConflictStrategy": args.addToRootConflictStrategy, "allowDuplicateKeys": args.allowDuplicateKeys, "description": args.description, "field": args.field, "if": args.if, "ignoreFailure": args.ignoreFailure, "onFailures": args.onFailures, "tag": args.tag, "targetField": args.targetField, }, opts); } /** * A collection of arguments for invoking ElasticsearchIngestProcessorJson. */ export interface ElasticsearchIngestProcessorJsonArgs { /** * Flag that forces the parsed JSON to be added at the top level of the document. `targetField` must not be set when this option is chosen. */ addToRoot?: boolean; /** * When set to `replace`, root fields that conflict with fields from the parsed JSON will be overridden. When set to `merge`, conflicting fields will be merged. Only applicable if `addToRoot` is set to `true`. */ addToRootConflictStrategy?: string; /** * When set to `true`, the JSON parser will not fail if the JSON contains duplicate keys. Instead, the last encountered value for any duplicate key wins. */ allowDuplicateKeys?: boolean; /** * Description of the processor. */ description?: string; /** * The field to be parsed. */ field: string; /** * Conditionally execute the processor */ if?: string; /** * Ignore failures for the processor. */ ignoreFailure?: boolean; /** * Handle failures for the processor. */ onFailures?: string[]; /** * Identifier for the processor. */ tag?: string; /** * The field that the converted structured object will be written into. Any existing content in this field will be overwritten. */ targetField?: string; } /** * A collection of values returned by ElasticsearchIngestProcessorJson. */ export interface ElasticsearchIngestProcessorJsonResult { /** * Flag that forces the parsed JSON to be added at the top level of the document. `targetField` must not be set when this option is chosen. */ readonly addToRoot?: boolean; /** * When set to `replace`, root fields that conflict with fields from the parsed JSON will be overridden. When set to `merge`, conflicting fields will be merged. Only applicable if `addToRoot` is set to `true`. */ readonly addToRootConflictStrategy?: string; /** * When set to `true`, the JSON parser will not fail if the JSON contains duplicate keys. Instead, the last encountered value for any duplicate key wins. */ readonly allowDuplicateKeys?: boolean; /** * Description of the processor. */ readonly description?: string; /** * The field to be parsed. */ readonly field: string; /** * Internal identifier of the resource. */ readonly id: string; /** * Conditionally execute the processor */ readonly if?: string; /** * Ignore failures for the processor. */ readonly ignoreFailure?: boolean; /** * JSON representation of this data source. */ readonly json: string; /** * Handle failures for the processor. */ readonly onFailures?: string[]; /** * Identifier for the processor. */ readonly tag?: string; /** * The field that the converted structured object will be written into. Any existing content in this field will be overwritten. */ readonly targetField?: string; } export function elasticsearchIngestProcessorJsonOutput(args: ElasticsearchIngestProcessorJsonOutputArgs, opts?: pulumi.InvokeOptions): pulumi.Output { return pulumi.output(args).apply(a => elasticsearchIngestProcessorJson(a, opts)) } /** * A collection of arguments for invoking ElasticsearchIngestProcessorJson. */ export interface ElasticsearchIngestProcessorJsonOutputArgs { /** * Flag that forces the parsed JSON to be added at the top level of the document. `targetField` must not be set when this option is chosen. */ addToRoot?: pulumi.Input; /** * When set to `replace`, root fields that conflict with fields from the parsed JSON will be overridden. When set to `merge`, conflicting fields will be merged. Only applicable if `addToRoot` is set to `true`. */ addToRootConflictStrategy?: pulumi.Input; /** * When set to `true`, the JSON parser will not fail if the JSON contains duplicate keys. Instead, the last encountered value for any duplicate key wins. */ allowDuplicateKeys?: pulumi.Input; /** * Description of the processor. */ description?: pulumi.Input; /** * The field to be parsed. */ field: pulumi.Input; /** * Conditionally execute the processor */ if?: pulumi.Input; /** * Ignore failures for the processor. */ ignoreFailure?: pulumi.Input; /** * Handle failures for the processor. */ onFailures?: pulumi.Input[]>; /** * Identifier for the processor. */ tag?: pulumi.Input; /** * The field that the converted structured object will be written into. Any existing content in this field will be overwritten. */ targetField?: pulumi.Input; }