Skip to main content
Pre-release

This release is a pre-release and may not be stable for production use.

th2 gRPC crawler data processor library (0.2.0)

This project contains the gRPC interface to implement if you want to create your own crawler data processor.

The crawler data processor work with the crawler

How to transform template

  1. Create a directory with the same name as project name (use underscores instead of dashes) under src/main/proto directory (remove other files and directories if they exist).
  2. Place your custom .proto files in created directory. Pay attention to package specifier and import statements.
  3. Edit release_version and vcs_url properties in gradle.properties file.
  4. Edit rootProject.name variable in settings.gradle file. This will be the name of Java package.
  5. Edit package_info.json file in order to specify name and version for Python package (create file if it's absent).
  6. Edit parameters of setup.py in setup function invocation such as: author, author_email, url. Do not edit the others.
  7. Edit README.md file according to the new project.

Note that the name of created directory under src/main/proto directory is used in Python (it's a package name).

How to maintain project

  1. Make your changes.
  2. Up version of Java package in gradle.properties file.
  3. Up version of Python package in package_info.json file.
  4. Commit everything.

How to run project

Java

If you wish to manually create and publish package for Java, run these command:

gradle --no-daemon clean build publish artifactoryPublish \
       -Pbintray_user=${BINTRAY_USER} \
       -Pbintray_key=${BINTRAY_KEY}

BINTRAY_USER and BINTRAY_KEY are parameters for publishing.

Python

If you wish to manually create and publish package for Python:

  1. Generate services by gradle:
       gradle --no-daemon clean generateProto
    
    You can find the generated files by following path: src/gen/main/services/python
  2. Generate code from .proto files and publish everything:
    pip install -r requirements.txt
    python setup.py generate
    python setup.py sdist
    twine upload --repository-url ${PYPI_REPOSITORY_URL} --username ${PYPI_USER} --password ${PYPI_PASSWORD} dist/*
    
    PYPI_REPOSITORY_URL, PYPI_USER and PYPI_PASSWORD are parameters for publishing.

Changes:

v0.2.0 (Breaking changes)

Braking:

  • Use list of MessageID instead of mapping between session and MessageID. User now will have to specify MessageID for both directions in the response if he or she needs to set a checkpoint. The list should contain a single MessageID for each pair alias + direction. If more than one is found the last one (according to their sequences) will be taken.
  • The rpc methods was renamed according to the Protobuf naming convention (uses PascalCase).
  • The event and message IDs from the response to connect method are removed because this functionality requires additional improvements on Crawler's side.

Added:

  • New method that will be invoked by the crawler each time the new interval is started.

Metadata

Release files for th2-grpc-crawler-data-processor 0.2.0.dev1828532784

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for th2-grpc-crawler-data-processor 0.2.0.dev1828532784
File Size Uploaded
th2_grpc_crawler_data_processor-0.2.0.dev1828532784.tar.gz 10.1 kB Details

Release files / th2_grpc_crawler_data_processor-0.2.0.dev1828532784.tar.gz

Download URL th2_grpc_crawler_data_processor-0.2.0.dev1828532784.tar.gz
Size 10.1 kB
Tags Source
SHA-256 checksum
How to use checksums
25b9e9e91a16a995463b1cc9b6e966ba45c308b35606caccf09249c4a3c43859
BLAKE2b-256 checksum
How to use checksums
440fbbbc17b3e23a91775d847d1215b9f97d550650afc030df8a1607b6e4f88b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/3.8.0 pkginfo/1.8.2 readme-renderer/32.0 requests/2.27.1 requests-toolbelt/0.9.1 urllib3/1.26.8 tqdm/4.62.3 importlib-metadata/4.11.0 keyring/23.5.0 rfc3986/2.0.0 colorama/0.4.4 CPython/3.9.10

Release history Release notifications | RSS feed

0.3.2

1 release file

0.3.1

1 release file

0.3.0

1 release file

0.2.0

1 release file

This release

0.1.0

1 release file

0.0.1

1 release file

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page