Biblioteca cliente de Python

El paquete python-bztcp proporciona una implementación íntegramente en Python del protocolo TCP de Benzinga para la transmisión de datos financieros.

Repositorio de GitHub

Ver el código fuente y contribuir

​

Características

• Compatible con Python 2.6+ y Python 3
• Sin dependencias externas
• Admite mensajes grandes
• Lógica de reintentos configurable con backoff exponencial

​

Instalación

Instala la librería con setup.py:

git clone https://github.com/Benzinga/python-bztcp.git
cd python-bztcp
python setup.py install

​

Inicio rápido

Prueba el cliente con la demo integrada:

Python 3 / 2.7+

python -m bztcp USERNAME API_KEY

Con configuración de reintentos

python -m bztcp USERNAME API_KEY RETRIES DELAY BACKOFF

Python 2.6

python -m bztcp.__main__ USERNAME API_KEY

​

Uso básico

La clase bztcp.client.Client gestiona la conexión y el streaming:

from __future__ import print_function
from bztcp.client import Client

client = Client(username='USERNAME', key='API_KEY')

for content in client.content_items():
    title = content.get('title', None)
    print(title)

​

Opciones de configuración

​

Configuración de reintentos

Configura el comportamiento de los reintentos con un backoff exponencial:

from bztcp.client import Client

client = Client(
    username='USERNAME',
    key='API_KEY',
    retries=5,      # Número máximo de intentos de reintento
    delay=90,       # Retraso inicial en segundos
    backoff=2       # Multiplicador de retroceso exponencial
)

for content in client.content_items():
    title = content.get('title', None)
    print(title)

Parameter	Descripción	Valor predeterminado
username	Tu nombre de usuario TCP de Benzinga	Obligatorio
key	Tu clave de acceso a la API	Obligatorio
retries	Número máximo de reintentos	-
delay	Pausa inicial entre reintentos (segundos)	-
backoff	Multiplicador para el backoff exponencial	-

​

Uso avanzado

​

Manejo de mensajes de bajo nivel

Para un control detallado sobre el estado de la conexión y los mensajes individuales:

from bztcp.client import Client, STATUS_STREAM
from bztcp.exceptions import BzException

client = Client(username='USERNAME', key='API_KEY')

while True:
    try:
        msg = client.next_msg()
        
        if msg.status == STATUS_STREAM:
            print(f"Content item: {msg.data}")
        else:
            print(f"Status: {msg.status}")
            
    except KeyboardInterrupt:
        print("Cancelled, disconnecting.")
        client.disconnect()
        break
        
    except BzException as bze:
        print(f"BZ Error: {bze}")
        break

​

Constantes de estado de mensajes

Estado	Descripción
STATUS_STREAM	Mensaje de contenido de streaming normal

​

Métodos clave

Método	Descripción
content_items()	Generador que devuelve diccionarios de content
next_msg()	Devuelve el siguiente objeto de mensaje sin procesar
disconnect()	Desconecta limpiamente del servidor

​

Gestión de errores

La biblioteca lanza la excepción BzException para errores propios de Benzinga:

from bztcp.exceptions import BzException

try:
    for content in client.content_items():
        process(content)
except BzException as e:
    print(f"Error de Benzinga: {e}")
except Exception as e:
    print(f"Error inesperado: {e}")

​

Ejemplo completo

#!/usr/bin/env python
from __future__ import print_function
import json
from bztcp.client import Client

def main():
    client = Client(
        username='YOUR_USERNAME',
        key='YOUR_API_KEY',
        retries=5,
        delay=30,
        backoff=2
    )
    
    print("Starting Benzinga TCP stream...")
    
    for content in client.content_items():
        # Extraer campos clave
        content_id = content.get('id')
        title = content.get('title', 'No title')
        channels = content.get('channels', [])
        tickers = [t['name'] for t in content.get('tickers', [])]
        
        # Imprimir resumen
        print(f"[{content_id}] {title}")
        if channels:
            print(f"  Channels: {', '.join(channels)}")
        if tickers:
            print(f"  Tickers: {', '.join(tickers)}")
        print()

if __name__ == '__main__':
    main()

​

Ver también

• Guía de conexión - Detalles del servidor y autenticación
• Formato de mensaje - Referencia de la estructura JSON
• Cliente Go - Implementación alternativa en Go