Hi I'm writing a custom search command, and I'm running into the following error: Failed to write buffer of size 21 to external process file descriptor (Broken pipe) The custom search is an eventing command (command name is 'sum'): #!/usr/bin/python
import exec_anaconda
exec_anaconda.exec_anaconda()
import pandas as pd
import os,sys
import logging, logging.handlers
import splunk
from splunklib.searchcommands import dispatch, EventingCommand, Configuration, Option, validators
@Configuration()
class ExEventsCommand(EventingCommand):
def transform(self, records):
l = list(records)
l.sort(key=lambda r: r['_raw'])
return l
if __name__ == "__main__":
dispatch(ExEventsCommand, sys.argv, sys.stdin, sys.stdout, __name__) The error occurs only sometimes - it looks like it is dependent on the amount of data that is returned by the search. This is illustrated by the following searches: index = _internal | head 10000 | sum (no error)
index = _internal | head 100000 | sum (error)
... View more