fixed issue zabbix#30 by adding Hostname support to Sender and AsyncSender

Author: aiantsen

examples/sender/asynchronous/agent_config_using.py

@@ -22,7 +22,7 @@ async def main():
 
  # Send a value to a Zabbix server/proxy with specified parameters
  # Parameters: (host, key, value, clock)
- response = await sender.send_value('host', 'item.key', 'value', 1695713666)
+ response = await sender.send_value(sender.host, 'item.key', 'value', 1695713666)
 
  # Check if the value sending was successful
  if response.failed == 0:

examples/sender/synchronous/agent_config_using.py

@@ -15,7 +15,7 @@
 
 # Send a value to a Zabbix server/proxy with specified parameters
 # Parameters: (host, key, value, clock)
-response = sender.send_value('host', 'item.key', 'value', 1695713666)
+response = sender.send_value(sender.host, 'item.key', 'value', 1695713666)
 
 # Check if the value sending was successful
 if response.failed == 0:

zabbix_utils/aiosender.py

@@ -69,6 +69,7 @@ def __init__(self, server: Optional[str] = None, port: int = 10051,
  self.use_ipv6 = use_ipv6
  self.tls = {}
 
+ self.host = None
  self.source_ip = None
  self.chunk_size = chunk_size
  self.compression = compression
@@ -105,6 +106,7 @@ def __read_config(self, config: configparser.SectionProxy) -> None:
  for cluster in server_row.split(','):
  self.clusters.append(Cluster(cluster.strip().split(';')))
 
+ self.host = config.get('Hostname')
  if 'SourceIP' in config:
  self.source_ip = config.get('SourceIP')
 
@@ -310,4 +312,4 @@ async def send_value(self, host: str, key: str,
  TrapperResponse: Response from Zabbix server/proxy.
  """
 
- return await self.send([ItemValue(host, key, value, clock, ns)])
+ return await self.send([ItemValue(host or self.host or '', key, value, clock, ns)])

zabbix_utils/sender.py

@@ -66,6 +66,7 @@ def __init__(self, server: Optional[str] = None, port: int = 10051,
  self.use_ipv6 = use_ipv6
  self.tls = {}
 
+ self.host = None
  self.source_ip = None
  self.chunk_size = chunk_size
  self.compression = compression
@@ -102,6 +103,7 @@ def __read_config(self, config: configparser.SectionProxy) -> None:
  for cluster in server_row.split(','):
  self.clusters.append(Cluster(cluster.strip().split(';')))
 
+ self.host = config.get('Hostname')
  if 'SourceIP' in config:
  self.source_ip = config.get('SourceIP')
 
@@ -218,7 +220,6 @@ def __send_to_cluster(self, cluster: Cluster, packet: bytes) -> Optional[Tuple[N
 
  if response and response.get('response') != 'success':
  if response.get('redirect'):
- print(response)
  log.debug(
  'Packet was redirected from %s to %s. Proxy group revision: %s.',
  active_node,
@@ -312,4 +313,4 @@ def send_value(self, host: str, key: str,
  TrapperResponse: Response from Zabbix server/proxy.
  """
 
- return self.send([ItemValue(host, key, value, clock, ns)])
+ return self.send([ItemValue(host or self.host or '', key, value, clock, ns)])