-
Processors
- AttributeRollingWindow
- AttributesToCSV
- AttributesToJSON
- CalculateRecordStats
- CaptureChangeMySQL
- CompressContent
- ConnectWebSocket
- ConsumeAMQP
- ConsumeAzureEventHub
- ConsumeElasticsearch
- ConsumeGCPubSub
- ConsumeIMAP
- ConsumeJMS
- ConsumeKafka
- ConsumeKinesisStream
- ConsumeMQTT
- ConsumePOP3
- ConsumeSlack
- ConsumeTwitter
- ConsumeWindowsEventLog
- ControlRate
- ConvertCharacterSet
- ConvertRecord
- CopyAzureBlobStorage_v12
- CopyS3Object
- CountText
- CryptographicHashContent
- DebugFlow
- DecryptContentAge
- DecryptContentPGP
- DeduplicateRecord
- DeleteAzureBlobStorage_v12
- DeleteAzureDataLakeStorage
- DeleteByQueryElasticsearch
- DeleteDynamoDB
- DeleteFile
- DeleteGCSObject
- DeleteGridFS
- DeleteMongo
- DeleteS3Object
- DeleteSFTP
- DeleteSQS
- DetectDuplicate
- DistributeLoad
- DuplicateFlowFile
- EncodeContent
- EncryptContentAge
- EncryptContentPGP
- EnforceOrder
- EvaluateJsonPath
- EvaluateXPath
- EvaluateXQuery
- ExecuteGroovyScript
- ExecuteProcess
- ExecuteScript
- ExecuteSQL
- ExecuteSQLRecord
- ExecuteStreamCommand
- ExtractAvroMetadata
- ExtractEmailAttachments
- ExtractEmailHeaders
- ExtractGrok
- ExtractHL7Attributes
- ExtractRecordSchema
- ExtractText
- FetchAzureBlobStorage_v12
- FetchAzureDataLakeStorage
- FetchBoxFile
- FetchDistributedMapCache
- FetchDropbox
- FetchFile
- FetchFTP
- FetchGCSObject
- FetchGoogleDrive
- FetchGridFS
- FetchS3Object
- FetchSFTP
- FetchSmb
- FilterAttribute
- FlattenJson
- ForkEnrichment
- ForkRecord
- GenerateFlowFile
- GenerateRecord
- GenerateTableFetch
- GeoEnrichIP
- GeoEnrichIPRecord
- GeohashRecord
- GetAsanaObject
- GetAwsPollyJobStatus
- GetAwsTextractJobStatus
- GetAwsTranscribeJobStatus
- GetAwsTranslateJobStatus
- GetAzureEventHub
- GetAzureQueueStorage_v12
- GetDynamoDB
- GetElasticsearch
- GetFile
- GetFTP
- GetGcpVisionAnnotateFilesOperationStatus
- GetGcpVisionAnnotateImagesOperationStatus
- GetHubSpot
- GetMongo
- GetMongoRecord
- GetS3ObjectMetadata
- GetSFTP
- GetShopify
- GetSmbFile
- GetSNMP
- GetSplunk
- GetSQS
- GetWorkdayReport
- GetZendesk
- HandleHttpRequest
- HandleHttpResponse
- IdentifyMimeType
- InvokeHTTP
- InvokeScriptedProcessor
- ISPEnrichIP
- JoinEnrichment
- JoltTransformJSON
- JoltTransformRecord
- JSLTTransformJSON
- JsonQueryElasticsearch
- ListAzureBlobStorage_v12
- ListAzureDataLakeStorage
- ListBoxFile
- ListDatabaseTables
- ListDropbox
- ListenFTP
- ListenHTTP
- ListenOTLP
- ListenSlack
- ListenSyslog
- ListenTCP
- ListenTrapSNMP
- ListenUDP
- ListenUDPRecord
- ListenWebSocket
- ListFile
- ListFTP
- ListGCSBucket
- ListGoogleDrive
- ListS3
- ListSFTP
- ListSmb
- LogAttribute
- LogMessage
- LookupAttribute
- LookupRecord
- MergeContent
- MergeRecord
- ModifyBytes
- ModifyCompression
- MonitorActivity
- MoveAzureDataLakeStorage
- Notify
- PackageFlowFile
- PaginatedJsonQueryElasticsearch
- ParseEvtx
- ParseNetflowv5
- ParseSyslog
- ParseSyslog5424
- PartitionRecord
- PublishAMQP
- PublishGCPubSub
- PublishJMS
- PublishKafka
- PublishMQTT
- PublishSlack
- PutAzureBlobStorage_v12
- PutAzureCosmosDBRecord
- PutAzureDataExplorer
- PutAzureDataLakeStorage
- PutAzureEventHub
- PutAzureQueueStorage_v12
- PutBigQuery
- PutBoxFile
- PutCloudWatchMetric
- PutDatabaseRecord
- PutDistributedMapCache
- PutDropbox
- PutDynamoDB
- PutDynamoDBRecord
- PutElasticsearchJson
- PutElasticsearchRecord
- PutEmail
- PutFile
- PutFTP
- PutGCSObject
- PutGoogleDrive
- PutGridFS
- PutKinesisFirehose
- PutKinesisStream
- PutLambda
- PutMongo
- PutMongoBulkOperations
- PutMongoRecord
- PutRecord
- PutRedisHashRecord
- PutS3Object
- PutSalesforceObject
- PutSFTP
- PutSmbFile
- PutSNS
- PutSplunk
- PutSplunkHTTP
- PutSQL
- PutSQS
- PutSyslog
- PutTCP
- PutUDP
- PutWebSocket
- PutZendeskTicket
- QueryAirtableTable
- QueryAzureDataExplorer
- QueryDatabaseTable
- QueryDatabaseTableRecord
- QueryRecord
- QuerySalesforceObject
- QuerySplunkIndexingStatus
- RemoveRecordField
- RenameRecordField
- ReplaceText
- ReplaceTextWithMapping
- RetryFlowFile
- RouteHL7
- RouteOnAttribute
- RouteOnContent
- RouteText
- RunMongoAggregation
- SampleRecord
- ScanAttribute
- ScanContent
- ScriptedFilterRecord
- ScriptedPartitionRecord
- ScriptedTransformRecord
- ScriptedValidateRecord
- SearchElasticsearch
- SegmentContent
- SendTrapSNMP
- SetSNMP
- SignContentPGP
- SplitAvro
- SplitContent
- SplitExcel
- SplitJson
- SplitPCAP
- SplitRecord
- SplitText
- SplitXml
- StartAwsPollyJob
- StartAwsTextractJob
- StartAwsTranscribeJob
- StartAwsTranslateJob
- StartGcpVisionAnnotateFilesOperation
- StartGcpVisionAnnotateImagesOperation
- TagS3Object
- TailFile
- TransformXml
- UnpackContent
- UpdateAttribute
- UpdateByQueryElasticsearch
- UpdateCounter
- UpdateDatabaseTable
- UpdateRecord
- ValidateCsv
- ValidateJson
- ValidateRecord
- ValidateXml
- VerifyContentMAC
- VerifyContentPGP
- Wait
-
Controller Services
- ADLSCredentialsControllerService
- ADLSCredentialsControllerServiceLookup
- AmazonGlueSchemaRegistry
- ApicurioSchemaRegistry
- AvroReader
- AvroRecordSetWriter
- AvroSchemaRegistry
- AWSCredentialsProviderControllerService
- AzureBlobStorageFileResourceService
- AzureCosmosDBClientService
- AzureDataLakeStorageFileResourceService
- AzureEventHubRecordSink
- AzureStorageCredentialsControllerService_v12
- AzureStorageCredentialsControllerServiceLookup_v12
- CEFReader
- ConfluentEncodedSchemaReferenceReader
- ConfluentEncodedSchemaReferenceWriter
- ConfluentSchemaRegistry
- CSVReader
- CSVRecordLookupService
- CSVRecordSetWriter
- DatabaseRecordLookupService
- DatabaseRecordSink
- DatabaseTableSchemaRegistry
- DBCPConnectionPool
- DBCPConnectionPoolLookup
- DistributedMapCacheLookupService
- ElasticSearchClientServiceImpl
- ElasticSearchLookupService
- ElasticSearchStringLookupService
- EmailRecordSink
- EmbeddedHazelcastCacheManager
- ExcelReader
- ExternalHazelcastCacheManager
- FreeFormTextRecordSetWriter
- GCPCredentialsControllerService
- GCSFileResourceService
- GrokReader
- HazelcastMapCacheClient
- HikariCPConnectionPool
- HttpRecordSink
- IPLookupService
- JettyWebSocketClient
- JettyWebSocketServer
- JMSConnectionFactoryProvider
- JndiJmsConnectionFactoryProvider
- JsonConfigBasedBoxClientService
- JsonPathReader
- JsonRecordSetWriter
- JsonTreeReader
- Kafka3ConnectionService
- KerberosKeytabUserService
- KerberosPasswordUserService
- KerberosTicketCacheUserService
- LoggingRecordSink
- MapCacheClientService
- MapCacheServer
- MongoDBControllerService
- MongoDBLookupService
- PropertiesFileLookupService
- ProtobufReader
- ReaderLookup
- RecordSetWriterLookup
- RecordSinkServiceLookup
- RedisConnectionPoolService
- RedisDistributedMapCacheClientService
- RestLookupService
- S3FileResourceService
- ScriptedLookupService
- ScriptedReader
- ScriptedRecordSetWriter
- ScriptedRecordSink
- SetCacheClientService
- SetCacheServer
- SimpleCsvFileLookupService
- SimpleDatabaseLookupService
- SimpleKeyValueLookupService
- SimpleRedisDistributedMapCacheClientService
- SimpleScriptedLookupService
- SiteToSiteReportingRecordSink
- SlackRecordSink
- SmbjClientProviderService
- StandardAsanaClientProviderService
- StandardAzureCredentialsControllerService
- StandardDropboxCredentialService
- StandardFileResourceService
- StandardHashiCorpVaultClientService
- StandardHttpContextMap
- StandardJsonSchemaRegistry
- StandardKustoIngestService
- StandardKustoQueryService
- StandardOauth2AccessTokenProvider
- StandardPGPPrivateKeyService
- StandardPGPPublicKeyService
- StandardPrivateKeyService
- StandardProxyConfigurationService
- StandardRestrictedSSLContextService
- StandardS3EncryptionService
- StandardSSLContextService
- StandardWebClientServiceProvider
- Syslog5424Reader
- SyslogReader
- UDPEventRecordSink
- VolatileSchemaCache
- WindowsEventLogReader
- XMLFileLookupService
- XMLReader
- XMLRecordSetWriter
- YamlTreeReader
- ZendeskRecordSink
GetSNMP 2.0.0
- Bundle
- org.apache.nifi | nifi-snmp-nar
- Description
- Retrieves information from SNMP Agent with SNMP Get request and outputs a FlowFile with information in attributes and without any content
- Tags
- get, oid, snmp, walk
- Input Requirement
- ALLOWED
- Supports Sensitive Dynamic Properties
- false
-
Additional Details for GetSNMP 2.0.0
GetSNMP
Summary
This processor polls an SNMP agent to get information for a given OID or OIDs (Strategy = GET) or for all the subtree associated to a given OID or OIDs (Strategy = WALK). This processor supports SNMPv1, SNMPv2c and SNMPv3. The component is based on SNMP4J.
The processor can compile the SNMP Get PDU from the attributes of an input flowfile (multiple OIDs can be specified) or from a single OID specified in the processor property. In the former case, the processor will only consider the OIDs specified in the flowfile. The processor is looking for attributes prefixed with _ snmp$_. If such an attribute is found, the attribute name is split using the $ character. The second element must respect the OID format to be considered as a valid OID. The flowfile attribute value can be empty (it will be later filled with the retrieved value and written into the outgoing flowfile). When the processor is triggered, it sends the SNMP request and gets the information associated to request OID(s). Once response is received from the SNMP agent, a FlowFile is constructed. The FlowFile content is empty, all the information is written in the FlowFile attributes. In case of a single GET request, the properties associated to the received PDU are transferred into the FlowFile as attributes. In case of a WALK request, only the couples “OID/value” are transferred into the FlowFile as attributes. SNMP attributes names are prefixed with snmp$ prefix.
Regarding the attributes representing the couples “OID/value”, the attribute name has the following format:
- snmp$OID$SMI_Syntax_Value
where OID is the request OID, and SMI_Syntax_Value is the integer representing the type of the value associated to the OID. This value is provided to allow the SetSNMP processor setting values in the correct type.
SNMP Properties
In case of a single SNMP Get request, the following is the list of available standard SNMP properties which may come with the PDU: (“snmp$errorIndex”, “snmp$errorStatus”, “snmp$errorStatusText”, “snmp$nonRepeaters”, “snmp$requestID”, “snmp$type”)
-
SNMP Authentication Passphrase
Passphrase used for SNMP authentication protocol.
- Display Name
- SNMP Authentication Passphrase
- Description
- Passphrase used for SNMP authentication protocol.
- API Name
- snmp-authentication-passphrase
- Expression Language Scope
- Not Supported
- Sensitive
- true
- Required
- true
- Dependencies
-
- SNMP Security Level is set to any of [authPriv, authNoPriv]
-
SNMP Authentication Protocol
Hash based authentication protocol for secure authentication.
- Display Name
- SNMP Authentication Protocol
- Description
- Hash based authentication protocol for secure authentication.
- API Name
- snmp-authentication-protocol
- Allowable Values
-
- MD5
- SHA
- SHA224
- SHA256
- SHA384
- SHA512
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SNMP Security Level is set to any of [authPriv, authNoPriv]
-
SNMP Community
SNMPv1 and SNMPv2 use communities to establish trust between managers and agents. Most agents support three community names, one each for read-only, read-write and trap. These three community strings control different types of activities. The read-only community applies to get requests. The read-write community string applies to set requests. The trap community string applies to receipt of traps.
- Display Name
- SNMP Community
- Description
- SNMPv1 and SNMPv2 use communities to establish trust between managers and agents. Most agents support three community names, one each for read-only, read-write and trap. These three community strings control different types of activities. The read-only community applies to get requests. The read-write community string applies to set requests. The trap community string applies to receipt of traps.
- API Name
- snmp-community
- Default Value
- public
- Expression Language Scope
- Not Supported
- Sensitive
- true
- Required
- true
- Dependencies
-
- SNMP Version is set to any of [SNMPv1, SNMPv2c]
-
SNMP Agent Hostname
Hostname or network address of the SNMP Agent.
- Display Name
- SNMP Agent Hostname
- Description
- Hostname or network address of the SNMP Agent.
- API Name
- snmp-hostname
- Default Value
- localhost
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- true
-
OID
Each OID (object identifier) identifies a variable that can be read or set via SNMP. This value is not taken into account for an input flowfile and will be omitted. Can be set to emptystring when the OIDs are provided through flowfile.
- Display Name
- OID
- Description
- Each OID (object identifier) identifies a variable that can be read or set via SNMP. This value is not taken into account for an input flowfile and will be omitted. Can be set to emptystring when the OIDs are provided through flowfile.
- API Name
- snmp-oid
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
SNMP Agent Port
Port of the SNMP Agent.
- Display Name
- SNMP Agent Port
- Description
- Port of the SNMP Agent.
- API Name
- snmp-port
- Default Value
- 161
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- true
-
SNMP Privacy Protocol
Privacy allows for encryption of SNMP v3 messages to ensure confidentiality of data.
- Display Name
- SNMP Privacy Protocol
- Description
- Privacy allows for encryption of SNMP v3 messages to ensure confidentiality of data.
- API Name
- snmp-private-protocol
- Allowable Values
-
- DES
- 3DES
- AES128
- AES192
- AES256
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SNMP Security Level is set to any of [authPriv]
-
SNMP Privacy Passphrase
Passphrase used for SNMP privacy protocol.
- Display Name
- SNMP Privacy Passphrase
- Description
- Passphrase used for SNMP privacy protocol.
- API Name
- snmp-private-protocol-passphrase
- Expression Language Scope
- Not Supported
- Sensitive
- true
- Required
- true
- Dependencies
-
- SNMP Security Level is set to any of [authPriv]
-
Number of Retries
Set the number of retries when requesting the SNMP Agent.
- Display Name
- Number of Retries
- Description
- Set the number of retries when requesting the SNMP Agent.
- API Name
- snmp-retries
- Default Value
- 0
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
SNMP Security Level
SNMP version 3 provides extra security with User Based Security Model (USM). The three levels of security is 1. Communication without authentication and encryption (NoAuthNoPriv). 2. Communication with authentication and without encryption (AuthNoPriv). 3. Communication with authentication and encryption (AuthPriv).
- Display Name
- SNMP Security Level
- Description
- SNMP version 3 provides extra security with User Based Security Model (USM). The three levels of security is 1. Communication without authentication and encryption (NoAuthNoPriv). 2. Communication with authentication and without encryption (AuthNoPriv). 3. Communication with authentication and encryption (AuthPriv).
- API Name
- snmp-security-level
- Default Value
- noAuthNoPriv
- Allowable Values
-
- noAuthNoPriv
- authNoPriv
- authPriv
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SNMP Version is set to any of [SNMPv3]
-
SNMP Security Name
User name used for SNMP v3 Authentication.
- Display Name
- SNMP Security Name
- Description
- User name used for SNMP v3 Authentication.
- API Name
- snmp-security-name
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SNMP Version is set to any of [SNMPv3]
-
SNMP Strategy
SNMP strategy to use (SNMP Get or SNMP Walk)
- Display Name
- SNMP Strategy
- Description
- SNMP strategy to use (SNMP Get or SNMP Walk)
- API Name
- snmp-strategy
- Default Value
- GET
- Allowable Values
-
- GET
- WALK
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Textual OID
The textual form of the numeric OID to request. This property is user defined, not processed and appended to the outgoing flowfile.
- Display Name
- Textual OID
- Description
- The textual form of the numeric OID to request. This property is user defined, not processed and appended to the outgoing flowfile.
- API Name
- snmp-textual-oid
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
Timeout (ms)
Set the timeout in ms when requesting the SNMP Agent.
- Display Name
- Timeout (ms)
- Description
- Set the timeout in ms when requesting the SNMP Agent.
- API Name
- snmp-timeout
- Default Value
- 5000
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
SNMP Version
Three significant versions of SNMP have been developed and deployed. SNMPv1 is the original version of the protocol. More recent versions, SNMPv2c and SNMPv3, feature improvements in performance, flexibility and security.
- Display Name
- SNMP Version
- Description
- Three significant versions of SNMP have been developed and deployed. SNMPv1 is the original version of the protocol. More recent versions, SNMPv2c and SNMPv3, feature improvements in performance, flexibility and security.
- API Name
- snmp-version
- Default Value
- SNMPv1
- Allowable Values
-
- v1
- v2c
- v3
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
Name | Description |
---|---|
success | All FlowFiles that are received from the SNMP agent are routed to this relationship. |
failure | All FlowFiles that cannot received from the SNMP agent are routed to this relationship. |
Name | Description |
---|---|
snmp$<OID> | Response variable binding: OID (e.g. 1.3.6.1.4.1.343) and its value. |
snmp$errorIndex | Denotes the variable binding in which the error occured. |
snmp$errorStatus | The snmp4j error status of the PDU. |
snmp$errorStatusText | The description of error status. |
snmp$nonRepeaters | The number of non repeater variable bindings in a GETBULK PDU (currently not supported). |
snmp$requestID | The request ID associated with the PDU. |
snmp$type | The snmp4j numeric representation of the type of the PDU. |
snmp$typeString | The name of the PDU type. |
snmp$textualOid | This attribute will exist if and only if the strategy is GET and will be equal to the value given in Textual Oid property. |