Skip to content

Commit e29004a

Browse files
authored
Merge pull request #429 from splunk/DVPL-8273
documented how to access modular input metadata
2 parents a750f3b + 2f0eab1 commit e29004a

File tree

2 files changed

+23
-0
lines changed

2 files changed

+23
-0
lines changed

README.md

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,22 @@ Don't
227227
yield {'_time': time.time(), 'two': 2}
228228
```
229229

230+
### Access metadata of modular inputs app
231+
* In stream_events() method we can access modular input app metadata from InputDefinition object
232+
* See [GitHub Commit](https://github.com/splunk/splunk-sdk-python/blob/develop/examples/github_commits/bin/github_commits.py) Modular input App example for reference.
233+
```python
234+
def stream_events(self, inputs, ew):
235+
# other code
236+
237+
# access metadata (like server_host, server_uri, etc) of modular inputs app from InputDefinition object
238+
# here inputs is a InputDefinition object
239+
server_host = inputs.metadata["server_host"]
240+
server_uri = inputs.metadata["server_uri"]
241+
242+
# Get the checkpoint directory out of the modular input's metadata
243+
checkpoint_dir = inputs.metadata["checkpoint_dir"]
244+
```
245+
230246
### Changelog
231247

232248
The [CHANGELOG](CHANGELOG.md) contains a description of changes for each version of the SDK. For the latest version, see the [CHANGELOG.md](https://github.com/splunk/splunk-sdk-python/blob/master/CHANGELOG.md) on GitHub.

examples/github_commits/bin/github_commits.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,13 @@ def stream_events(self, inputs, ew):
146146
token = None
147147
if "token" in input_item:
148148
token = input_item["token"]
149+
150+
'''
151+
access metadata (like server_host, server_uri, etc) of modular inputs app from InputDefinition object
152+
here inputs is a InputDefinition object
153+
server_host = inputs.metadata["server_host"]
154+
server_uri = inputs.metadata["server_uri"]
155+
'''
149156
# Get the checkpoint directory out of the modular input's metadata
150157
checkpoint_dir = inputs.metadata["checkpoint_dir"]
151158

0 commit comments

Comments
 (0)